LocalManualEvent

A manually triggered single threaded cross-task event.

Note: the ownership can be shared between multiple fibers of the same thread.

struct LocalManualEvent {

import core.thread : Thread;;

template Waitable(CB, alias WAIT, alias CANCEL, alias DONE) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

auto asyncAwait(Duration timeout, string func) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

auto asyncAwaitUninterruptible(Duration timeout, string func) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

void asyncAwaitAny(string func) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

package @safe static

EventID ms_threadEvent;

bool opCast();

int emitCount();

int emitSingle();

int wait(int emit_count);

int wait(Duration timeout, int emit_count);

int waitUninterruptible();

int waitUninterruptible(int emit_count);

int waitUninterruptible(Duration timeout, int emit_count);

}

Destructor

~this ~this(): Undocumented in source.

Postblit

this(this) this(this): Undocumented in source.

Members

Functions

emit int emit(): Emits the signal, waking up all owners of the signal.
emitCount int emitCount(): A counter that is increased with every emit() call
emitSingle int emitSingle(): Emits the signal, waking up a single owners of the signal.
opCast bool opCast(): Undocumented in source. Be warned that the author may not have intended to support it.
wait int wait(): Acquires ownership and waits until the signal is emitted.
wait int wait(int emit_count)
int wait(Duration timeout, int emit_count): Acquires ownership and waits until the signal is emitted and the emit count is larger than a given one.
waitUninterruptible int waitUninterruptible()
int waitUninterruptible(int emit_count)
int waitUninterruptible(Duration timeout, int emit_count): Same as wait, but defers throwing any InterruptException.

Static variables

ms_threadEvent EventID ms_threadEvent;: Undocumented in source.

Meta

Source

See Implementation