ZipNSink

Undocumented in source.

class ZipNSink (

alias selector

E

TObserver

TObservables...

) {

alias ItemTypes = GetElementsTuple!TObservables;

alias Store = GetZipStoreType!(TObserver, TObservables);

TObservables sources;

TObserver observer;

Disposable cancel;

this(TObservables sources, TObserver observer);

bool hasElements();

static if(hasCompleted!TObserver)

bool isCompleted();

void enqueue();

static if(hasCompleted!TObserver)

void checkCompleted();

void failure(Exception e);

class ZipChildObserver(size_t index, TObserver, E);

}

Constructors

this this(TObservables sources, TObserver observer): Undocumented in source.

Members

Aliases

ItemTypes alias ItemTypes = GetElementsTuple!TObservables: Undocumented in source.
Store alias Store = GetZipStoreType!(TObserver, TObservables): Undocumented in source.

Classes

ZipChildObserver class ZipChildObserver(size_t index, TObserver, E): Undocumented in source.

Functions

checkCompleted void checkCompleted(): Undocumented in source. Be warned that the author may not have intended to support it.
enqueue void enqueue(): Undocumented in source. Be warned that the author may not have intended to support it.
failure void failure(Exception e): Undocumented in source. Be warned that the author may not have intended to support it.
hasElements bool hasElements(): 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.
run auto run(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

cancel Disposable cancel;: Undocumented in source.
gate Object gate;: Undocumented in source.
observer TObserver observer;: Undocumented in source.
sources TObservables sources;: Undocumented in source.
store Store store;: Undocumented in source.

Meta

Source

See Implementation

rx range zip aliases

GetZipStoreType

classes

structs

ZipStore

templates