SharedSender

Undocumented in source.

class SharedSender (

Sender

Scheduler

ResetLogic resetLogic

) if (

models!(Sender, isSender)

) {

import std.traits : ReturnType;;

alias Props = Properties!(Sender);

alias Value = Props.Value;

alias InternalValue = Props.InternalValue;

bool isCompleted();

void reset();

this(Sender sender, Scheduler scheduler);

auto connect(Receiver receiver);

}

Constructors

this this(Sender sender, Scheduler scheduler): Undocumented in source.

Members

Aliases

InternalValue alias InternalValue = Props.InternalValue: Undocumented in source.
Props alias Props = Properties!(Sender): Undocumented in source.
Value alias Value = Props.Value: Undocumented in source.

Functions

connect auto connect(Receiver receiver): Undocumented in source. Be warned that the author may not have intended to support it.
isCompleted bool isCompleted(): Undocumented in source. Be warned that the author may not have intended to support it.
reset void reset(): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

concurrency operations toshared classes

SharedSender

enums

ResetLogic

functions

toShared

structs

NullScheduler