Module: Async::HTTP::Protocol::HTTP2::Connection
Instance Attribute Summary collapse
-
#count ⇒ Object
readonly
Returns the value of attribute count.
-
#promises ⇒ Object
readonly
Returns the value of attribute promises.
-
#stream ⇒ Object
readonly
Returns the value of attribute stream.
Instance Method Summary collapse
- #close(error = nil) ⇒ Object
- #concurrency ⇒ Object
- #http1? ⇒ Boolean
- #http2? ⇒ Boolean
- #initialize ⇒ Object
- #peer ⇒ Object
- #read_in_background(task: Task.current) ⇒ Object
- #reusable? ⇒ Boolean
- #start_connection ⇒ Object
- #to_s ⇒ Object
- #version ⇒ Object
-
#viable? ⇒ Boolean
Can we use this connection to make requests?.
- #write_frame(frame) ⇒ Object
- #write_frames(&block) ⇒ Object
Instance Attribute Details
#count ⇒ Object (readonly)
Returns the value of attribute count.
118 119 120 |
# File 'lib/async/http/protocol/http2/connection.rb', line 118 def count @count end |
#promises ⇒ Object (readonly)
Returns the value of attribute promises.
112 113 114 |
# File 'lib/async/http/protocol/http2/connection.rb', line 112 def promises @promises end |
#stream ⇒ Object (readonly)
Returns the value of attribute stream.
58 59 60 |
# File 'lib/async/http/protocol/http2/connection.rb', line 58 def stream @stream end |
Instance Method Details
#close(error = nil) ⇒ Object
72 73 74 75 76 |
# File 'lib/async/http/protocol/http2/connection.rb', line 72 def close(error = nil) @reader = nil super end |
#concurrency ⇒ Object
120 121 122 |
# File 'lib/async/http/protocol/http2/connection.rb', line 120 def concurrency self.maximum_concurrent_streams end |
#http1? ⇒ Boolean
60 61 62 |
# File 'lib/async/http/protocol/http2/connection.rb', line 60 def http1? false end |
#http2? ⇒ Boolean
64 65 66 |
# File 'lib/async/http/protocol/http2/connection.rb', line 64 def http2? true end |
#initialize ⇒ Object
44 45 46 47 48 49 50 51 52 |
# File 'lib/async/http/protocol/http2/connection.rb', line 44 def initialize(*) super @count = 0 @reader = nil # Writing multiple frames at the same time can cause odd problems if frames are only partially written. So we use a semaphore to ensure frames are written in their entirety. @write_frame_guard = Async::Semaphore.new(1) end |
#peer ⇒ Object
114 115 116 |
# File 'lib/async/http/protocol/http2/connection.rb', line 114 def peer @stream.io end |
#read_in_background(task: Task.current) ⇒ Object
95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 |
# File 'lib/async/http/protocol/http2/connection.rb', line 95 def read_in_background(task: Task.current) task.async do |nested_task| nested_task.annotate("#{version} reading data for #{self.class}.") begin while !self.closed? self.consume_window self.read_frame end rescue IOError, EOFError, Errno::ECONNRESET, Errno::EPIPE, Async::Wrapper::Cancelled # Ignore. ensure close($!) end end end |
#reusable? ⇒ Boolean
129 130 131 |
# File 'lib/async/http/protocol/http2/connection.rb', line 129 def reusable? !(self.closed? || @stream.closed?) end |
#start_connection ⇒ Object
68 69 70 |
# File 'lib/async/http/protocol/http2/connection.rb', line 68 def start_connection @reader ||= read_in_background end |
#to_s ⇒ Object
54 55 56 |
# File 'lib/async/http/protocol/http2/connection.rb', line 54 def to_s "\#<#{self.class} #{@streams.count} active streams>" end |
#version ⇒ Object
133 134 135 |
# File 'lib/async/http/protocol/http2/connection.rb', line 133 def version VERSION end |
#viable? ⇒ Boolean
Can we use this connection to make requests?
125 126 127 |
# File 'lib/async/http/protocol/http2/connection.rb', line 125 def viable? @stream.connected? end |
#write_frame(frame) ⇒ Object
78 79 80 81 82 83 84 85 |
# File 'lib/async/http/protocol/http2/connection.rb', line 78 def write_frame(frame) # We don't want to write multiple frames at the same time. @write_frame_guard.acquire do super end @stream.flush end |
#write_frames(&block) ⇒ Object
87 88 89 90 91 92 93 |
# File 'lib/async/http/protocol/http2/connection.rb', line 87 def write_frames(&block) @write_frame_guard.acquire do super end @stream.flush end |