SharedStream

Undocumented in source.

shared

struct SharedStream (

T

) {

alias ElementType = T;

alias SubscriberDG = void delegate(T) nothrow @(safe) shared;

import concurrency.slist;;

this(SList!SubscriberDG dgs);

void emit(T t);

auto collect(DG dg);

}

Constructors

this this(SList!SubscriberDG dgs): Undocumented in source.

Members

Aliases

ElementType alias ElementType = T: Undocumented in source.
SubscriberDG alias SubscriberDG = void delegate(T) nothrow @(safe) shared: Undocumented in source.

Functions

collect auto collect(DG dg): Undocumented in source. Be warned that the author may not have intended to support it.
emit void emit(T t): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation