CombineLatestCoordinator

Undocumented in source.

class CombineLatestCoordinator (

TObserver

ElementTypes...

) {

this(TObserver observer, Disposable subscription);

void innerPut(ElementTypes[index] obj);

void innerCompleted();

void innerFailure(Exception e);

Object _gate;

shared(AtomicCounter) _counter;

bool[ElementTypes.length] _hasValues;

ElementTypes _values;

TObserver _observer;

Disposable _subscription;

}

Constructors

this this(TObserver observer, Disposable subscription): Undocumented in source.

Members

Functions

innerCompleted void innerCompleted(): Undocumented in source. Be warned that the author may not have intended to support it.
innerFailure void innerFailure(Exception e): Undocumented in source. Be warned that the author may not have intended to support it.
innerPut void innerPut(ElementTypes[index] obj): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

_counter shared(AtomicCounter) _counter;: Undocumented in source.
_gate Object _gate;: Undocumented in source.
_hasValues bool[ElementTypes.length] _hasValues;: Undocumented in source.
_observer TObserver _observer;: Undocumented in source.
_subscription Disposable _subscription;: Undocumented in source.
_values ElementTypes _values;: Undocumented in source.

Meta

Source

See Implementation

rx algorithm combineLatest classes

CombineLatestCoordinator

structs

templates

combineLatest