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
228 def initialize(*)
229   @signal = Signal.new
230   super
231 end

Public Instance methods

close(selector = Selector.new)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
233 def close(selector = Selector.new)
234   @signal.terminate
235   selector.deregister(@signal)
236   super
237 end
deselect_connection(connection, *)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
247 def deselect_connection(connection, *)
248   return super unless connection.options.stream
249 
250   super
251 
252   connection.signal = nil
253 end
select_connection(connection, selector)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
239 def select_connection(connection, selector)
240   return super unless connection.options.stream
241 
242   super
243   selector.register(@signal)
244   connection.signal = @signal
245 end