File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -246,7 +246,7 @@ def on_message(message)
246
246
queue = Queue . new
247
247
failure = nil
248
248
# failure = AdHoc.spawn(:failure) { -> m { terminate! } } # FIXME this leads to weird message processing ordering
249
- monitor = AdHoc . spawn ( :monitor ) do
249
+ monitor = AdHoc . spawn! ( :monitor ) do
250
250
failure = AdHoc . spawn ( :failure ) { -> m { m } }
251
251
failure << :link
252
252
-> m { queue << [ m , envelope . sender ] }
@@ -261,7 +261,7 @@ def on_message(message)
261
261
it 'links atomically' do
262
262
queue = Queue . new
263
263
failure = nil
264
- monitor = AdHoc . spawn ( :monitor ) do
264
+ monitor = AdHoc . spawn! ( :monitor ) do
265
265
failure = AdHoc . spawn ( name : :failure , link : true ) { -> m { m } }
266
266
-> m { queue << [ m , envelope . sender ] }
267
267
end
You can’t perform that action at this time.
0 commit comments