1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
module HTTP2
class Connection
include FlowBuffer
include Emitter
include BufferUtils
REQUEST_MANDATORY_HEADERS: Array[String]
RESPONSE_MANDATORY_HEADERS: Array[String]
CONNECTION_FRAME_TYPES: Array[Symbol]
HEADERS_FRAME_TYPES: Array[Symbol]
STREAM_OPEN_STATES: Array[Symbol]
attr_reader state: Symbol
attr_reader local_window: Integer
attr_reader remote_window: Integer
alias window local_window
attr_reader remote_settings: settings_hash
attr_reader local_settings: settings_hash
attr_reader pending_settings: settings_ary
attr_accessor active_stream_count: Integer
@stream_id: Integer
@active_stream_count: Integer
@last_stream_id: Integer
@streams: Hash[Integer, Stream]
@streams_recently_closed: Hash[Integer, Numeric]
@framer: Framer
type role_type = :client | :server
@local_role: role_type
@remote_role: role_type
@local_window_limit: Integer
@remote_window_limit: Integer
@compressor: Header::Compressor
@decompressor: Header::Decompressor
@error: Symbol?
@recv_buffer: String
@continuation: Array[frame]
@h2c_upgrade: Symbol?
@closed_since: Float?
@received_frame: bool
def closed?: () -> bool
def new_stream: (**untyped) -> Stream
def ping: (String) -> void
| (String) { () -> void } -> void
def goaway: (?Symbol, ?String) -> void
def window_update: (Integer increment) -> void
def settings: (settings_enum payload) -> void
def receive: (string data) -> void
alias << receive
def initialize: (?connection_opts) -> void
private
def send: (frame frame) -> void
def encode: (frame frame) -> void
def connection_frame?: (frame) -> bool
def connection_management: (frame) -> void
def ping_management: (frame) -> void
def validate_settings: (role_type, settings_enum) -> void
def connection_settings: (frame) -> void
def decode_headers: (frame) -> void
def encode_headers: (frame headers_frame) -> void
def activate_stream: (id: Integer, **untyped) -> Stream
def verify_stream_order: (Integer id) -> void
def verify_pseudo_headers: (frame) -> void
def _verify_pseudo_headers: (frame, Array[String]) -> void
def connection_error: (?Symbol error, ?msg: String?, ?e: StandardError?) -> void
end
end
|
