TaskPipe

Implements a unidirectional data pipe between two tasks.

final

class TaskPipe : ConnectionStream {

this(bool grow_when_full);

size_t bufferSize [@property getter];

size_t bufferSize [@property setter];

bool empty [@property getter];

ulong leastSize [@property getter];

bool dataAvailableForRead [@property getter];

bool connected [@property getter];

void close();

bool waitForData(Duration timeout);

const(ubyte)[] peek();

size_t read(ubyte[] dst, IOMode mode);

alias read = ConnectionStream.read;

static if(is(typeof(.OutputStream.outputStreamVersion)) && .OutputStream.outputStreamVersion > 1)

size_t write(const(ubyte)[] bytes, IOMode mode);

static if(!(is(typeof(.OutputStream.outputStreamVersion)) && .OutputStream.outputStreamVersion > 1))

size_t write(ubyte[] bytes, IOMode mode);

alias write = ConnectionStream.write;

void flush();

void finalize();

}

Constructors

this this(bool grow_when_full): Constructs a new pipe ready for use.

Members

Aliases

read alias read = ConnectionStream.read: Undocumented in source.
write alias write = ConnectionStream.write: Undocumented in source.

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
finalize void finalize(): Undocumented in source. Be warned that the author may not have intended to support it.
flush void flush(): Undocumented in source. Be warned that the author may not have intended to support it.
peek const(ubyte)[] peek(): Undocumented in source. Be warned that the author may not have intended to support it.
read size_t read(ubyte[] dst, IOMode mode): Undocumented in source. Be warned that the author may not have intended to support it.
waitForData bool waitForData(Duration timeout): Undocumented in source. Be warned that the author may not have intended to support it.
write size_t write(const(ubyte)[] bytes, IOMode mode): Undocumented in source. Be warned that the author may not have intended to support it.
write size_t write(ubyte[] bytes, IOMode mode): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

bufferSize size_t bufferSize [@property getter]
size_t bufferSize [@property setter]: Size of the (fixed) FIFO buffer used to transfer data between tasks
connected bool connected [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
dataAvailableForRead bool dataAvailableForRead [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
empty bool empty [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
leastSize ulong leastSize [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

index vibe stream taskpipe classes

TaskPipe