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)

rx subject classes

functions

interfaces

Subject