overrides the declaration of +@write_buffer+, which is now a thread-safe buffer responding to the same API.
Attributes
signal | [W] |
Public Class methods
new(*)
[show source]
# File lib/httpx/plugins/stream_bidi.rb 285 def initialize(*) 286 super 287 @write_buffer = BidiBuffer.new(@options.buffer_size) 288 end
Public Instance methods
interests()
rebuffers the +@write_buffer+ before calculating interests.
[show source]
# File lib/httpx/plugins/stream_bidi.rb 291 def interests 292 @write_buffer.rebuffer 293 294 super 295 end