Class: IOMultiplex::IOReactor::Buffered

Inherits:

IOMultiplex::IOReactor

• Object
• IOMultiplex::IOReactor
• IOMultiplex::IOReactor::Buffered

Defined in:

lib/iomultiplex/ioreactor/buffered.rb

Overview

Wraps around a buffered IO object When the read signal triggers for the IO object, it will continuously read in the main loops post processing until it receives a WaitReadable signal. This ensures any data left in the IO buffer after a read is correctly read without waiting for a read signal

Direct Known Subclasses

OpenSSL, OpenSSLUpgrading

Constant Summary

Constants included from Mixins::IOReactor::Write

Mixins::IOReactor::Write::WRITE_BUFFER_MAX, Mixins::IOReactor::Write::WRITE_SIZE

Constants included from Mixins::IOReactor::Read

Mixins::IOReactor::Read::READ_BUFFER_MAX, Mixins::IOReactor::Read::READ_SIZE

Instance Attribute Summary

Attributes inherited from IOMultiplex::IOReactor

#id, #io, #mode, #peer

Attributes included from Mixins::Logger

#logger, #logger_context

Instance Method Summary

• #initialize(io, mode = 'rw', id = nil) ⇒ Buffered constructor

  A new instance of Buffered.

Methods inherited from IOMultiplex::IOReactor

#addr, #attach, #close, #detach, #force_close, #peeraddr

Methods included from Mixins::IOReactor::Write

#handle_write, #write, #write_full?

Methods included from Mixins::IOReactor::Read

#discard, #handle_data, #handle_read, #pause, #read, #read_full?, #resume

Constructor Details

#initialize(io, mode = 'rw', id = nil) ⇒ Buffered

Returns a new instance of Buffered.

# File 'lib/iomultiplex/ioreactor/buffered.rb', line 27

def initialize(io, mode = 'rw', id = nil)
  super io, mode, id
end