ManualTimeWorker

Undocumented in source.

class ManualTimeWorker {

struct TimingWheels(T) via import concurrency.timingwheels : TimingWheels;;

alias VoidDelegate = void delegate() shared @(safe) via import concurrency.executor : VoidDelegate;;

import core.sync.mutex : Mutex;;

import core.sync.condition : Condition;;

import core.time : msecs, hnsecs;;

import core.time : msecs, hnsecs;;

import std.array : Appender;;

ManualTimeScheduler getScheduler();

Timer addTimer(TimerDelegate dg, Duration dur);

void cancelTimer(Timer timer);

Nullable!Duration timeUntilNextEvent();

void advance(Duration dur);

}

Constructors

this this(): Undocumented in source.

Members

Functions

addTimer Timer addTimer(TimerDelegate dg, Duration dur): Undocumented in source. Be warned that the author may not have intended to support it.
advance void advance(Duration dur): Undocumented in source. Be warned that the author may not have intended to support it.
cancelTimer void cancelTimer(Timer timer): Undocumented in source. Be warned that the author may not have intended to support it.
getScheduler ManualTimeScheduler getScheduler(): Undocumented in source. Be warned that the author may not have intended to support it.
lock auto lock(): Undocumented in source. Be warned that the author may not have intended to support it.
timeUntilNextEvent Nullable!Duration timeUntilNextEvent(): Undocumented in source. Be warned that the author may not have intended to support it.
wait void wait(): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation