class Async::HTTP::Protocol::HTTP2::Output
def write(chunk)
def write(chunk) until chunk.empty? maximum_size = @stream.available_frame_size # We try to avoid synchronization if possible: if maximum_size <= 0 @guard.synchronize do maximum_size = @stream.available_frame_size while maximum_size <= 0 @window_updated.wait(@guard) maximum_size = @stream.available_frame_size end end end break unless chunk = send_data(chunk, maximum_size) end end