1 |
class SupervisionContainerHelper |
18✔ |
2 |
@queue = nil |
18✔ |
3 |
class << self |
18✔ |
4 |
def reset! |
18✔ |
5 |
@queue = Queue.new |
× |
6 |
end
|
|
7 |
|
|
8 |
def done! |
18✔ |
9 |
@queue << :done |
× |
10 |
end
|
|
11 |
|
|
12 |
def pop! |
18✔ |
13 |
@queue.pop
|
× |
14 |
end
|
|
15 |
end
|
|
16 |
end
|
|
17 |
|
|
18 |
class MyContainerActor |
18✔ |
19 |
include Celluloid
|
18✔ |
20 |
|
|
21 |
attr_reader :args
|
18✔ |
22 |
|
|
23 |
def initialize(*args) |
18✔ |
24 |
@args = args
|
× |
25 |
ready |
× |
26 |
end
|
|
27 |
|
|
28 |
def running? |
18✔ |
29 |
:yep
|
× |
30 |
end
|
|
31 |
|
|
32 |
def ready |
18✔ |
33 |
SupervisionContainerHelper.done!
|
× |
34 |
end
|
|
35 |
end
|