class Async::Wrapper

def wait_writable(duration = nil)
	raise WaitError if @writable
	
	self.reactor = Task.current.reactor
	
	begin
		@writable = Fiber.current
		wait_for(duration)
	ensure
		@writable = nil
		@monitor.interests = interests if @monitor
	end
end