TakeReceiver

Undocumented in source.

struct TakeReceiver (

Receiver

Value

) {

Receiver receiver;

StopSource stopSource;

static if(is(Value == void))

void setValue();

static if(!(is(Value == void)))

void setValue(Value e);

void setDone();

void setError(Throwable t);

mixin ForwardExtensionPoints!receiver ;

}

Members

Functions

setDone void setDone(): Undocumented in source. Be warned that the author may not have intended to support it.
setError void setError(Throwable t): Undocumented in source. Be warned that the author may not have intended to support it.
setValue void setValue(): Undocumented in source. Be warned that the author may not have intended to support it.
setValue void setValue(Value e): Undocumented in source. Be warned that the author may not have intended to support it.

Mixins

__anonymous mixin ForwardExtensionPoints!receiver: Undocumented in source.

Variables

receiver Receiver receiver;: Undocumented in source.
stopSource StopSource stopSource;: Undocumented in source.

Mixed In Members

From `mixin ForwardExtensionPoints!receiver`

getStopToken auto getStopToken(): Undocumented in source. Be warned that the author may not have intended to support it.
getScheduler auto getScheduler(): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

concurrency stream take functions

take

structs

TakeReceiver

templates

TakeOp