StreamReceiver

Undocumented in source.

struct StreamReceiver (

State

) {

static if(is(State.StreamSenderValue == void))

void setValue();

static if(!(is(State.StreamSenderValue == void)))

void setValue(State.StreamSenderValue value);

void setError(Throwable t);

void setDone();

StopToken getStopToken();

mixin ForwardExtensionPoints!(receiver) ;

}

Members

Functions

getStopToken StopToken getStopToken(): Undocumented in source. Be warned that the author may not have intended to support it.
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(State.StreamSenderValue value): Undocumented in source. Be warned that the author may not have intended to support it.

Mixins

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

Variables

state State state;: 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 flatmapbase classes

State

enums

OnOverlap

structs

templates

FlatMapBaseStreamOp