Method: Tipi::HTTP2StreamHandler#get_body_chunk

Defined in:
lib/tipi/http2_stream.rb

#get_body_chunk(request, buffered_only = false) ⇒ Object 



82
83
84
85
86
87
88
89
90
91
92
93
94
 
# File 'lib/tipi/http2_stream.rb', line 82

def get_body_chunk(request, buffered_only = false)
  @buffered_chunks ||= []
  return @buffered_chunks.shift unless @buffered_chunks.empty?
  return nil if @complete

  begin
    @get_body_chunk_fiber = Fiber.current
    suspend
  ensure
    @get_body_chunk_fiber = nil
  end
  @buffered_chunks.shift
end