Generator

"stream" or "generator" class, one which keeps producing new records for processing at throttled rate

class Generator : ISuspendable {

TimerEvent timer;

StreamProcessor!(ProcessingTask) stream_processor;

void start();

void resume();

void suspend();

bool suspended();

bool generate();

}

Constructors

this this(): Undocumented in source.

Members

Functions

generate bool generate(): Undocumented in source. Be warned that the author may not have intended to support it.
resume void resume(): Undocumented in source. Be warned that the author may not have intended to support it.
start void start(): Undocumented in source. Be warned that the author may not have intended to support it.
suspend void suspend(): Undocumented in source. Be warned that the author may not have intended to support it.
suspended bool suspended(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

counter int counter;: Undocumented in source.
stream_processor StreamProcessor!(ProcessingTask) stream_processor;: Undocumented in source.
timer TimerEvent timer;: Undocumented in source.

Inherited Members

From ISuspendable

suspend void suspend(): Requests that further processing be temporarily suspended, until resume() is called.
resume void resume(): Requests that processing be resumed.
suspended bool suspended()

Meta

Source

See Implementation

ocean task util StreamProcessor_test classes