@@ -1382,8 +1382,8 @@ def self.new_blocked_by1(blocker, *args, &block)
1382
1382
blocker_delayed = blocker . promise . delayed
1383
1383
delayed = blocker_delayed ? LockFreeStack . new . push ( blocker_delayed ) : nil
1384
1384
promise = new ( delayed , 1 , *args , &block )
1385
- ensure
1386
1385
blocker . add_callback :callback_notify_blocked , promise , 0
1386
+ promise
1387
1387
end
1388
1388
1389
1389
def self . new_blocked_by2 ( blocker1 , blocker2 , *args , &block )
@@ -1400,16 +1400,16 @@ def self.new_blocked_by2(blocker1, blocker2, *args, &block)
1400
1400
blocker_delayed2 ? LockFreeStack . of1 ( blocker_delayed2 ) : nil
1401
1401
end
1402
1402
promise = new ( delayed , 2 , *args , &block )
1403
- ensure
1404
1403
blocker1 . add_callback :callback_notify_blocked , promise , 0
1405
1404
blocker2 . add_callback :callback_notify_blocked , promise , 1
1405
+ promise
1406
1406
end
1407
1407
1408
1408
def self . new_blocked_by ( blockers , *args , &block )
1409
1409
delayed = blockers . reduce ( nil , &method ( :add_delayed ) )
1410
1410
promise = new ( delayed , blockers . size , *args , &block )
1411
- ensure
1412
1411
blockers . each_with_index { |f , i | f . add_callback :callback_notify_blocked , promise , i }
1412
+ promise
1413
1413
end
1414
1414
1415
1415
def self . add_delayed ( delayed , blocker )
0 commit comments