AsyncSubject

class AsyncSubject : Subject!E(

E

) {

Disposable subscribe(Observer!E observer);

auto subscribe(T observer);

void unsubscribe(Observer!E observer);

void put(E value);

void completed();

void failure(Exception e);

}

Members

Functions

completed void completed()
failure void failure(Exception e)
put void put(E value)
subscribe Disposable subscribe(Observer!E observer)
subscribe auto subscribe(T observer)
unsubscribe void unsubscribe(Observer!E observer)

Meta

Source

See Implementation

rx subject classes

interfaces

Subject