Class: Rev::BufferedIO

Class

Rev::BufferedIO

In:

lib/rev/buffered_io.rb

Parent:

A buffered I/O class witch fits into the Rev Watcher framework. It provides both an observer which reads data as it‘s received from the wire and a buffered writer which stores data and writes it out each time the socket becomes writable.

This class is primarily meant as a base class for other streams which need non-blocking writing, and is used to implement Rev‘s Socket class and its associated subclasses.

Methods

buffered_write close closed? new on_close on_read on_readable on_write_complete output_buffer_size schedule_write write write_nonblock write_output_buffer

Classes and Modules

Class Rev::BufferedIO::Writer

Constants

INPUT_SIZE = 16384 Maximum number of bytes to consume at once

Public Class methods

Public Instance methods

Close the BufferedIO stream

Is the IO object closed?

Called whenever the IO object hits EOF

Called whenever the IO object receives data

on_write_complete()

Called whenever a write completes and the output buffer is empty

output_buffer_size()

Number of bytes are currently in the output buffer

Write data in a buffered, non-blocking manner

Protected Instance methods

buffered_write(data)

Buffered writer

Inherited callback from IOWatcher

schedule_write()

write_nonblock(data)

Wrapper for handling reset connections and EAGAIN

write_output_buffer()

Attempt to write the contents of the output buffer