class Async::Semaphore
def wait
def wait return unless blocking? @waiting.stack(FiberNode.new(Fiber.current)) do Fiber.scheduler.transfer while blocking? end end
def wait return unless blocking? @waiting.stack(FiberNode.new(Fiber.current)) do Fiber.scheduler.transfer while blocking? end end