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)
246246 queue = Queue . new
247247 failure = nil
248248 # 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
250250 failure = AdHoc . spawn ( :failure ) { -> m { m } }
251251 failure << :link
252252 -> m { queue << [ m , envelope . sender ] }
@@ -261,7 +261,7 @@ def on_message(message)
261261 it 'links atomically' do
262262 queue = Queue . new
263263 failure = nil
264- monitor = AdHoc . spawn ( :monitor ) do
264+ monitor = AdHoc . spawn! ( :monitor ) do
265265 failure = AdHoc . spawn ( name : :failure , link : true ) { -> m { m } }
266266 -> m { queue << [ m , envelope . sender ] }
267267 end
You can’t perform that action at this time.
0 commit comments