Generator

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

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