@@ -1382,8 +1382,8 @@ def self.new_blocked_by1(blocker, *args, &block)
13821382 blocker_delayed = blocker . promise . delayed
13831383 delayed = blocker_delayed ? LockFreeStack . new . push ( blocker_delayed ) : nil
13841384 promise = new ( delayed , 1 , *args , &block )
1385- ensure
13861385 blocker . add_callback :callback_notify_blocked , promise , 0
1386+ promise
13871387 end
13881388
13891389 def self . new_blocked_by2 ( blocker1 , blocker2 , *args , &block )
@@ -1400,16 +1400,16 @@ def self.new_blocked_by2(blocker1, blocker2, *args, &block)
14001400 blocker_delayed2 ? LockFreeStack . of1 ( blocker_delayed2 ) : nil
14011401 end
14021402 promise = new ( delayed , 2 , *args , &block )
1403- ensure
14041403 blocker1 . add_callback :callback_notify_blocked , promise , 0
14051404 blocker2 . add_callback :callback_notify_blocked , promise , 1
1405+ promise
14061406 end
14071407
14081408 def self . new_blocked_by ( blockers , *args , &block )
14091409 delayed = blockers . reduce ( nil , &method ( :add_delayed ) )
14101410 promise = new ( delayed , blockers . size , *args , &block )
1411- ensure
14121411 blockers . each_with_index { |f , i | f . add_callback :callback_notify_blocked , promise , i }
1412+ promise
14131413 end
14141414
14151415 def self . add_delayed ( delayed , blocker )
0 commit comments