module HTTPX::Plugins::StreamBidi::ConnectionMethods

  1. lib/httpx/plugins/stream_bidi.rb

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

Methods

Public Class

  1. new

Public Instance

  1. call
  2. interests
  3. signal

Attributes

signal [W]

Public Class methods

new(*)
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
365 def initialize(*)
366   super
367 
368   return unless @options.stream
369 
370   @write_buffer = BidiBuffer.new(@options.buffer_size)
371 end

Public Instance methods

call()
[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
382 def call
383   return super unless @options.stream && (error = @signal.error)
384 
385   on_error(error)
386 end
interests()

rebuffers the +@write_buffer+ before calculating interests.

[show source] 
    # File lib/httpx/plugins/stream_bidi.rb
374 def interests
375   return super unless @options.stream
376 
377   @write_buffer.rebuffer
378 
379   super
380 end