Nursery

A Nursery is a place for senders to be ran in, while being a Sender itself. Stopping the Nursery cancels all senders. When any Sender completes with an Error all Senders are canceled as well. Cancellation is signaled with a StopToken. Senders themselves bare the responsibility to respond to stop requests. When cancellation happens all Senders are waited on for completion. Senders can be added to the Nursery at any time. Senders are only started when the Nursery itself is being awaited on.

class Nursery : StopSource {

eponymoustemplate isSender(T) via import concurrency.sender : isSender, OperationalStateBase;;

interface OperationalStateBase via import concurrency.sender : isSender, OperationalStateBase;;

import core.sync.mutex : Mutex;;

import concepts;;

alias Value = void;

this();

bool stop();

StopToken getStopToken();

void run(Nullable!Sender sender);

void run(Sender sender);

auto connect(Receiver receiver);

}

Constructors

this this(): Undocumented in source.

Members

Aliases

Value alias Value = void: Undocumented in source.

Functions

connect auto connect(Receiver receiver): Undocumented in source. Be warned that the author may not have intended to support it.
connect auto connect(Receiver receiver): Undocumented in source. Be warned that the author may not have intended to support it.
getStopToken StopToken getStopToken(): Undocumented in source. Be warned that the author may not have intended to support it.
run void run(Nullable!Sender sender): Undocumented in source. Be warned that the author may not have intended to support it.
run void run(Sender sender): Undocumented in source. Be warned that the author may not have intended to support it.
stop bool stop(): Undocumented in source. Be warned that the author may not have intended to support it.
stop bool stop(): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From StopSource

stop bool stop(): Undocumented in source. Be warned that the author may not have intended to support it.
stop bool stop(): Undocumented in source. Be warned that the author may not have intended to support it.
isStopRequested bool isStopRequested(): Undocumented in source. Be warned that the author may not have intended to support it.
isStopRequested bool isStopRequested(): Undocumented in source. Be warned that the author may not have intended to support it.
reset void reset(): resets the internal state, only do this if you are sure nothing else is looking at this...