concurrency

Modules

asyncscope

module concurrency.asyncscope

Undocumented in source.

bitfield

module concurrency.bitfield

Undocumented in source.

data

module concurrency.data

error

module concurrency.error

Undocumented in source.

executor

module concurrency.executor

Undocumented in source.

fork

module concurrency.fork

Undocumented in source.

nursery

module concurrency.nursery

Undocumented in source.

operations

module concurrency.operations

Undocumented in source.

receiver

module concurrency.receiver

Undocumented in source.

scheduler

module concurrency.scheduler

Undocumented in source.

sender

module concurrency.sender

Undocumented in source.

signal

module concurrency.signal

Undocumented in source.

slist

module concurrency.slist

Undocumented in source.

stoptoken

module concurrency.stoptoken

Undocumented in source.

stream

module concurrency.stream

Undocumented in source.

thread

module concurrency.thread

Undocumented in source.

timer

module concurrency.timer

Undocumented in source.

timingwheels

module concurrency.timingwheels

taken from https://github.com/ikod/timingwheels

utils

module concurrency.utils

Undocumented in source.

Members

Enums

Cancelled

enum Cancelled

Undocumented in source.

Functions

isMainThread

bool isMainThread()

Undocumented in source. Be warned that the author may not have intended to support it.

setTopLevelStopSource

void setTopLevelStopSource(StopSource stopSource)

Undocumented in source. Be warned that the author may not have intended to support it.

syncWait

auto syncWait(Sender sender, StopSource stopSource)

Start the Sender and waits until it completes, cancels, or has an error.

syncWait

auto syncWait(Sender sender)

Undocumented in source. Be warned that the author may not have intended to support it.

sync_wait

deprecated auto sync_wait(Sender sender, StopSource stopSource)

Undocumented in source. Be warned that the author may not have intended to support it.

sync_wait

deprecated auto sync_wait(Sender sender)

Undocumented in source. Be warned that the author may not have intended to support it.

Static variables

parentStopSource

StopSource parentStopSource;

Undocumented in source.

Structs

Result

struct Result(T)

Undocumented in source.

SyncWaitReceiver2

struct SyncWaitReceiver2(Value)

Undocumented in source.

Templates

match

template match(Handlers...)

matches over the result of syncWait

• concurrency
• ut