SharedSender

Undocumented in source.

class SharedSender (

Sender

Scheduler

) if (

models!(Sender, isSender)

) {

import std.traits : ReturnType;;

import concurrency.slist;;

import concurrency.bitfield;;

alias Value = Sender.Value;

struct ValueRep;

alias ValueRep = Value;

alias InternalValue = Algebraic!(Exception, ValueRep, Done);

alias DG = void delegate(InternalValue) nothrow @(safe) shared;

struct SharedSenderOp(Receiver);

class SharedSenderState;

struct SharedSenderReceiver;

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

DG alias DG = void delegate(InternalValue) nothrow @(safe) shared: Undocumented in source.
InternalValue alias InternalValue = Algebraic!(Exception, ValueRep, Done): Undocumented in source.
Value alias Value = Sender.Value: Undocumented in source.
ValueRep alias ValueRep = Value: Undocumented in source.

Classes

SharedSenderState class SharedSenderState: 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.

Structs

Done struct Done: Undocumented in source.
SharedSenderOp struct SharedSenderOp(Receiver): Undocumented in source.
SharedSenderReceiver struct SharedSenderReceiver: Undocumented in source.
ValueRep struct ValueRep: Undocumented in source.

Meta

Source

See Implementation

concurrency operations toshared classes

SharedSender

functions

toShared