Module: HTTPX::Plugins::StreamBidi::ConnectionMethods

Defined in:

lib/httpx/plugins/stream_bidi.rb

Overview

overrides the declaration of @write_buffer, which is now a thread-safe buffer responding to the same API.

Instance Attribute Summary

• #signal ⇒ Object writeonly

  Sets the attribute signal.

Instance Method Summary

• #initialize ⇒ Object
• #interests ⇒ Object

  rebuffers the @write_buffer before calculating interests.

Instance Attribute Details

#signal=(value) ⇒ Object (writeonly)

Sets the attribute signal

Parameters:

• value —

  the value to set the attribute signal to.

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

def signal=(value)
  @signal = value
end

Instance Method Details

#initialize ⇒ Object

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

def initialize(*)
  super
  @write_buffer = BidiBuffer.new(@options.buffer_size)
end

#interests ⇒ Object

rebuffers the @write_buffer before calculating interests.

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

def interests
  @write_buffer.rebuffer

  super
end