ImplementTestPushPeekFilter

Undocumented in source.

Members

Functions

consume
void consume(size_t n)
Undocumented in source. Be warned that the author may not have intended to support it.
peek
const(ulong)[] peek(size_t n)
Undocumented in source. Be warned that the author may not have intended to support it.
push
size_t push(const(ulong)[] buf)
Undocumented in source. Be warned that the author may not have intended to support it.

Mixins

__anonymous
mixin FiberSwitch
Undocumented in source.

Variables

buffer
ulong[] buffer;
Undocumented in source.

Mixed In Members

From mixin FiberSwitch

_flod_fiber
Fiber _flod_fiber;
Undocumented in source.
spawn
void spawn()

Start the next driver in the pipeline in a new fiber (but do not call it yet).

stop
void stop()

Make sure that the fiber has finished execution.

Meta