Sha256: 6e3ad2dd33479b7e074d1fb6a4d7b5e3e0bd56ada9beea234715ecbffa554aa4
Contents?: true
Size: 1.36 KB
Versions: 1
Compression:
Stored size: 1.36 KB
Contents
# frozen_string_literal: true # Released under the MIT License. # Copyright, 2019-2024, by Samuel Williams. require_relative "connection" module Protocol module HTTP2 class Client < Connection def initialize(framer) super(framer, 1) end def local_stream_id?(id) id.odd? end def remote_stream_id?(id) id.even? end def valid_remote_stream_id?(stream_id) stream_id.even? end def send_connection_preface(settings = []) if @state == :new @framer.write_connection_preface send_settings(settings) yield if block_given? read_frame do |frame| unless frame.is_a? SettingsFrame raise ProtocolError, "First frame must be #{SettingsFrame}, but got #{frame.class}" end end else raise ProtocolError, "Cannot send connection preface in state #{@state}" end end def create_push_promise_stream raise ProtocolError, "Cannot create push promises from client!" end def receive_push_promise(frame) if frame.stream_id == 0 raise ProtocolError, "Cannot receive headers for stream 0!" end if stream = @streams[frame.stream_id] # This is almost certainly invalid: promised_stream, request_headers = stream.receive_push_promise(frame) return promised_stream, request_headers end end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
protocol-http2-0.22.0 | lib/protocol/http2/client.rb |