@@ -48,22 +48,26 @@ def on_message(msg)
4848end
4949
5050master = Master . spawn ( name : 'master' , supervise : true )
51- # => #<Concurrent::Actor::Reference:0x7ff3aa0d1380 /master (Master)>
51+ # => #<Concurrent::Actor::Reference:0x7fd443366568 /master (Master)>
5252listener = master . ask! ( :listener )
53- # => #<Concurrent::Actor::Reference:0x7ff3aa8776e8 /master/listener1 (Listener)>
54- listener . ask! ( :number ) # => 73
53+ # => #<Concurrent::Actor::Reference:0x7fd44335cf68 /master/listener1 (Listener)>
54+ listener . ask! ( :number ) # => 20
55+
56+ listener . tell ( :crash )
57+ # => #<Concurrent::Actor::Reference:0x7fd44335cf68 /master/listener1 (Listener)>
58+ listener . ask! ( :number ) # => 41
5559
5660master << :crash
57- # => #<Concurrent::Actor::Reference:0x7ff3aa0d1380 /master (Master)>
61+ # => #<Concurrent::Actor::Reference:0x7fd443366568 /master (Master)>
5862
59- sleep 0.1 # => 1
63+ sleep 0.1 # => 0
6064
6165# ask for listener again, old one is terminated
6266listener . ask! ( :terminated? ) # => true
6367listener = master . ask! ( :listener )
64- # => #<Concurrent::Actor::Reference:0x7ff3ab147110 /master/listener1 (Listener)>
65- listener . ask! ( :number ) # => 48
68+ # => #<Concurrent::Actor::Reference:0x7fd4433357b0 /master/listener1 (Listener)>
69+ listener . ask! ( :number ) # => 12
6670
67- master . ask! ( :terminate! ) # => [true, true]
71+ master . ask! ( :terminate! ) # => [[ true] , true]
6872
6973sleep 0.1 # => 0
0 commit comments