class Async::HTTP::Body::Writable

def initialize(length = nil, queue: Async::Queue.new)

Parameters:
  • queue (Async::Queue) -- Specify a different queue implementation, e.g. `Async::LimitedQueue.new(8)` to enable back-pressure streaming.
  • length (Integer) -- The length of the response body if known. 
def initialize(length = nil, queue: Async::Queue.new)
	@queue = queue
	
	@length = length
	
	@count = 0
	
	@finished = false
	
	@closed = false
	@error = nil
end