concurrency ~master (2022-01-07T14:23:47Z)

State

concurrency stream flatmapbase
Undocumented in source.
final
class State : StopSource (
TStreamSenderValue
TSenderValue
Receiver
OnOverlap overlap
) {
import concurrency.bitfield;;
import concurrency.stoptoken;;
import std.exception : assumeWontThrow;;
alias DG = CollectDelegate!(SenderValue);
alias StreamSenderValue = TStreamSenderValue;
alias SenderValue = TSenderValue;
alias onOverlap = overlap;
DG dg;
Receiver receiver;
static if(!is(StreamSenderValue == void))
StreamSenderValue value;
Throwable throwable;
Semaphore semaphore;
StopCallback cb;
static if(overlap == OnOverlap.latest)
StopSource innerStopSource;
shared
SharedBitField!Flags bitfield;
this(DG dg, Receiver receiver);
bool stop();
bool stop();
}

Constructors

this
this(DG dg, Receiver receiver)
Undocumented in source.

Members

Aliases

DG
alias DG = CollectDelegate!(SenderValue)
Undocumented in source.
SenderValue
alias SenderValue = TSenderValue
Undocumented in source.
StreamSenderValue
alias StreamSenderValue = TStreamSenderValue
Undocumented in source.
onOverlap
alias onOverlap = overlap
Undocumented in source.

Functions

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.

Variables

bitfield
SharedBitField!Flags bitfield;
Undocumented in source.
cb
StopCallback cb;
Undocumented in source.
dg
DG dg;
Undocumented in source.
innerStopSource
StopSource innerStopSource;
Undocumented in source.
receiver
Receiver receiver;
Undocumented in source.
semaphore
Semaphore semaphore;
Undocumented in source.
throwable
Throwable throwable;
Undocumented in source.
value
StreamSenderValue value;
Undocumented in source.

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...

Meta

Source

See Implementation

concurrency stream flatmapbase classesenumsstructstemplates

Page generated by adrdox