FiberSelectReader

class FiberSelectReader : IFiberSelectProtocol {

}

Constructors

this this(IInputDevice input, SelectFiber fiber, IOWarning warning_e, IOError error_e, size_t buffer_size): Constructor.
this this(typeof(super) other, size_t buffer_size): Constructor

Members

Aliases

Consumer alias Consumer = size_t delegate(void[] data): Consumer callback delegate type
IInputDevice alias IInputDevice = .IInputDevice: Input device

Functions

consume bool consume(Consumer consume): Invokes consume with the data that are currently available and haven't yet been consumed. If the amount of data is sufficient, consume must return the number of bytes it consumed. Otherwise if consume consumed all data and needs more input data to be read from the I/O device, it must return a value greater than the number of data bytes passed to it.
consumed_data void[] consumed_data()
read typeof(this) read(T value): Reads T.sizeof bytes from the socket and writes it to 'value' Suspends if not enough data is available and resumes when the data became available
readConsume typeof(this) readConsume(Consumer consume): Reads data from the input conduit, appends it to the data buffer and invokes consume with the data that is currently available and hasn't yet been consumed. If consume feels that the amount of data passed to it is sufficient, it must return the number of bytes it consumed. Otherwise if consume consumed all the data and still needs more input data to be read from the I/O device, it must return a value greater than length of the the data passed to it. The fiber is then suspended to wait for more data to be available from the input device, and consume is invoked again with the newly available data.
readRaw typeof(this) readRaw(ubyte[] data_out): Reads data.length bytes from the socket and writes them to the array.
receive size_t receive(): Reads data from the input conduit and appends them to the data buffer, waiting for data to be read from the input conduit if
remaining_data void[] remaining_data()
reset typeof(this) reset(): Resets the amount of consumed/available data to 0.
transmit bool transmit(Event events): Reads data from the input conduit and appends them to the data buffer.

Static variables

default_buffer_size size_t default_buffer_size;: Default input buffer size (16 kB).

Inherited Members

From IFiberSelectProtocol

SelectFiber alias SelectFiber = .SelectFiber: Local aliases
IOWarning alias IOWarning = .IOWarning: Undocumented in source.
IOError alias IOError = .IOError: Undocumented in source.
conduit ISelectable conduit;: I/O device
events_ Event events_;: Events to register the I/O device for.
warning_e IOWarning warning_e;: IOWarning exception instance
error_e IOError error_e;: IOError exception instance
fileHandle Handle fileHandle()
events Event events()
error_code int error_code()
handle bool handle(Event events): Resumes the fiber coroutine and handle the events reported for the conduit. The fiber must be suspended (HOLD state).
transmitLoop void transmitLoop(): Registers this instance in the select dispatcher and repeatedly calls transmit() until the transmission is finished.
transmit bool transmit(Event events): Reads/writes data from/to super.conduit for which events have been reported.

FiberSelectReader

Constructors

Members

Aliases

Functions

Static variables

Inherited Members

From IFiberSelectProtocol

Meta

Source