ZipNSink

Undocumented in source.

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