Method: HTTP::Protocol::HTTP2::Connection#receive_headers

Defined in:

lib/http/protocol/http2/connection.rb

#receive_headers(frame) ⇒ Object

# File 'lib/http/protocol/http2/connection.rb', line 262

def receive_headers(frame)
  if frame.stream_id == 0
    raise ProtocolError, "Cannot receive headers for stream 0!"
  end
  
  if stream = @streams[frame.stream_id]
    stream.receive_headers(frame)
    
    if stream.closed?
      @streams.delete(stream.id)
    end
  elsif frame.stream_id > @remote_stream_id
    if @streams.count < self.maximum_concurrent_streams
      stream = create_stream(frame.stream_id)
      stream.receive_headers(frame)
      
      @remote_stream_id = stream.id
      @streams[stream.id] = stream
    else
      raise ProtocolError, "Exceeded maximum concurrent streams"
    end
  end
end