class Stream
Definitions
def prepare_input(length)
Prepare the input stream which will be used for incoming data frames.
Implementation
def prepare_input(length)
if @input.nil?
@input = Input.new(self, length)
else
raise ArgumentError, "Input body already prepared!"
end
end
def send_body(body, trailer = nil)
Set the body and begin sending it.
Implementation
def send_body(body, trailer = nil)
@output = Output.new(self, body, trailer)
@output.start
end
def finish_output(error = nil)
Called when the output terminates normally.
Implementation
def finish_output(error = nil)
return if self.closed?
trailer = @output&.trailer
@output = nil
if error
send_reset_stream(::Protocol::HTTP2::Error::INTERNAL_ERROR)
else
# Write trailer?
if trailer&.any?
send_headers(nil, trailer, ::Protocol::HTTP2::END_STREAM)
else
send_data(nil, ::Protocol::HTTP2::END_STREAM)
end
end
end
def closed(error)
When the stream transitions to the closed state, this method is called. There are roughly two ways this can happen:
- A frame is received which causes this stream to enter the closed state. This method will be invoked from the background reader task.
- A frame is sent which causes this stream to enter the closed state. This method will be invoked from that task. While the input stream is relatively straight forward, the output stream can trigger the second case above
Implementation
def closed(error)
super
if input = @input
@input = nil
input.close_write(error)
end
if output = @output
@output = nil
output.stop(error)
end
if pool = @pool and @connection
pool.release(@connection)
end
return self
end