SharedSender.SharedSenderState

Undocumented in source.

class SharedSender(Sender, Scheduler)

static

class SharedSenderState : StopSource {

import std.traits : ReturnType;;

alias Op = OpType!(Sender, SharedSenderReceiver);

SharedSender parent;

SList!DG dgs;

Nullable!InternalValue value;

this(SharedSender parent);

}

Constructors

this this(SharedSender parent): Undocumented in source.

Members

Aliases

Op alias Op = OpType!(Sender, SharedSenderReceiver): Undocumented in source.

Variables

dgs SList!DG dgs;: Undocumented in source.
op Op op;: Undocumented in source.
parent SharedSender parent;: Undocumented in source.
value Nullable!InternalValue 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 operations toshared SharedSender aliases

classes

SharedSenderState

constructors

this

functions

structs