class Async::Condition
def signal(value = nil)
Signal to a given task that it should resume operations.
def signal(value = nil) return if @waiting.empty? waiting = self.exchange waiting.each do |fiber| Fiber.scheduler.resume(fiber, value) if fiber.alive? end return nil end