DeferReceiver

Undocumented in source.

struct DeferReceiver (

Value

Receiver

) {

import concurrency.receiver;;

alias DG = CollectDelegate!(Value);

Receiver receiver;

void delegate() @(safe) nothrow reset;

static if(!is(Value : void))

void setValue(Value value);

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

void setValue();

void setError(Throwable t);

void setDone();

mixin ForwardExtensionPoints!(receiver) ;

}

Members

Aliases

DG alias DG = CollectDelegate!(Value): Undocumented in source.

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(Value value): 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.

Mixins

__anonymous mixin ForwardExtensionPoints!(receiver): Undocumented in source.

Variables

dg DG dg;: Undocumented in source.
receiver Receiver receiver;: Undocumented in source.
reset void delegate() @(safe) nothrow reset;: 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 defer functions

deferStream

structs

DeferReceiver

templates

DeferStreamOp