SubjectObject

Represents an object that is both an observable sequence as well as an observer. Each notification is broadcasted to all subscribed observers.

class SubjectObject : Subject!E(

) {

this();

void put(E obj);

void completed();

void failure(Exception error);

Disposable subscribe(T observer);

Disposable subscribe(Observer!E observer);

void unsubscribe(Observer!E observer);

}

Constructors

this this()

Members

Functions

completed void completed()
failure void failure(Exception error)
put void put(E obj)
subscribe Disposable subscribe(T observer)
subscribe Disposable subscribe(Observer!E observer)
unsubscribe void unsubscribe(Observer!E observer)

Examples

1 import std.array : appender;
2 
3 auto data = appender!(int[])();
4 auto subject = new SubjectObject!int;
5 auto disposable = subject.subscribe(observerObject!(int)(data));
6 assert(disposable !is null);
7 subject.put(0);
8 subject.put(1);
9 
10 import std.algorithm : equal;
11 
12 assert(equal(data.data, [0, 1]));
13 
14 disposable.dispose();
15 subject.put(2);
16 assert(equal(data.data, [0, 1]));

rx subject classes

functions

interfaces

Subject