Class: HTTPX::Plugins::StreamBidi::HTTP2Bidi

Inherits:

Connection::HTTP2

• Object
• Connection::HTTP2
• HTTPX::Plugins::StreamBidi::HTTP2Bidi

Defined in:

lib/httpx/plugins/stream_bidi.rb

Overview

Extension of the Connection::HTTP2 class, which adds functionality to deal with a request that can’t be drained and must be interleaved with the response streams.

The streams keeps send DATA frames while there’s data; when they’re ain’t, the stream is kept open; it must be explicitly closed by the end user.

Constant Summary

Constants inherited from Connection::HTTP2

Connection::HTTP2::MAX_CONCURRENT_REQUESTS

Constants included from Loggable

Loggable::COLORS, Loggable::USE_DEBUG_LOG

Instance Attribute Summary

Attributes inherited from Connection::HTTP2

#pending, #streams

Instance Method Summary

• #initialize ⇒ HTTP2Bidi constructor

  A new instance of HTTP2Bidi.

Methods inherited from Connection::HTTP2

#<<, #close, #consume, #empty?, #exhausted?, #handle_error, #interests, #ping, #send, #timeout, #waiting_for_ping?

Methods included from Loggable

#log, #log_exception, #log_redact

Methods included from Callbacks

#callbacks_for?, #emit, #on, #once

Constructor Details

#initialize ⇒ HTTP2Bidi

Returns a new instance of HTTP2Bidi.

# File 'lib/httpx/plugins/stream_bidi.rb', line 20

def initialize(*)
  super
  @lock = Thread::Mutex.new
end