module HTTPX::Plugins::StreamBidi::InstanceMethods

  1. lib/httpx/plugins/stream_bidi.rb

Methods

Public Class

  1. new

Public Instance

  1. close
  2. deselect_connection
  3. select_connection

Public Class methods

new(*)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
177 def initialize(*)
178   @signal = Signal.new
179   super
180 end

Public Instance methods

close(selector = Selector.new)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
182 def close(selector = Selector.new)
183   @signal.terminate
184   selector.deregister(@signal)
185   super(selector)
186 end
deselect_connection(connection, *)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
194 def deselect_connection(connection, *)
195   super
196   connection.signal = nil
197 end
select_connection(connection, selector)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
188 def select_connection(connection, selector)
189   super
190   selector.register(@signal)
191   connection.signal = @signal
192 end