Processor

Utility mixin template implementing dynamic timeout based event subscribing + static backlog Creates methods waitFor<fn>, processfn, fetchOldfnLog, clearfnLog

@safe

mixin template Processor (

string fn

Arg

size_t backlog

Duration ttl

) {

struct Backlog;

bool delegate(Arg) nothrow @(safe[]) processors;

Backlog[backlog] backlogs;

void process(Arg arg);

bool tryWaitFor(bool delegate(Arg) nothrow @(safe) check, Duration timeout, Arg ret);

Arg waitFor(bool delegate(Arg) nothrow @(safe) check, Duration timeout);

Arg[] fetchOldLog(bool delegate(Arg) nothrow @(safe) check, bool returnIt);

void clearLog();

}

Members

Functions

clearLog void clearLog(): Undocumented in source. Be warned that the author may not have intended to support it.
fetchOldLog Arg[] fetchOldLog(bool delegate(Arg) nothrow @(safe) check, bool returnIt): Undocumented in source. Be warned that the author may not have intended to support it.
process void process(Arg arg): Undocumented in source. Be warned that the author may not have intended to support it.
tryWaitFor bool tryWaitFor(bool delegate(Arg) nothrow @(safe) check, Duration timeout, Arg ret): Undocumented in source. Be warned that the author may not have intended to support it.
waitFor Arg waitFor(bool delegate(Arg) nothrow @(safe) check, Duration timeout): Undocumented in source. Be warned that the author may not have intended to support it.

Structs

Backlog struct Backlog: Undocumented in source.

Variables

backlogs Backlog[backlog] backlogs;: Undocumented in source.
processors bool delegate(Arg) nothrow @(safe[]) processors;: Undocumented in source.

Processor

Members

Functions

Structs

Variables

Meta

Source