lib/async/notification.rb in async-2.2.1 vs lib/async/notification.rb in async-2.3.0

@@ -11,12 +11,10 @@
 	class Notification < Condition
 		# Signal to a given task that it should resume operations.
 		def signal(value = nil, task: Task.current)
 			return if @waiting.empty?
 			
-			Fiber.scheduler.push Signal.new(@waiting, value)
-			
-			@waiting = []
+			Fiber.scheduler.push Signal.new(self.exchange, value)
 			
 			return nil
 		end
 		
 		Signal = Struct.new(:waiting, :value) do