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
159 def initialize(*)
160   @signal = Signal.new
161   super
162 end

Public Instance methods

close(selector = Selector.new)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
164 def close(selector = Selector.new)
165   @signal.terminate
166   selector.deregister(@signal)
167   super(selector)
168 end
deselect_connection(connection, *)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
176 def deselect_connection(connection, *)
177   super
178   connection.signal = nil
179 end
select_connection(connection, selector)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
170 def select_connection(connection, selector)
171   super
172   selector.register(@signal)
173   connection.signal = @signal
174 end