class Async::HTTP::Body::Writable
def write(chunk)
def write(chunk) if @stopped raise @stopped end # TODO should this yield if the queue is full? @count += 1 @queue.enqueue(chunk) end
def write(chunk) if @stopped raise @stopped end # TODO should this yield if the queue is full? @count += 1 @queue.enqueue(chunk) end