ReplaySubject

class ReplaySubject : Subject!E(

) {

this(size_t bufferSize);

Disposable subscribe(TObserver observer);

Disposable subscribe(Observer!E observer);

void put(E obj);

void completed();

void failure(Exception e);

}

Constructors

this this(size_t bufferSize)

Members

Functions

completed void completed()
failure void failure(Exception e)
put void put(E obj)
subscribe Disposable subscribe(TObserver observer)
subscribe Disposable subscribe(Observer!E observer)

Examples

auto sub = new ReplaySubject!int(1);
.put(sub, 1);

int[] buf;
auto d = sub.doSubscribe!(v => buf ~= v);
scope (exit)
    d.dispose();

assert(buf.length == 1);
assert(buf[0] == 1);

auto sub = new ReplaySubject!int(1);
.put(sub, 1);
.put(sub, 2);

int[] buf;
auto d = sub.doSubscribe!(v => buf ~= v);
scope (exit)
    d.dispose();

assert(buf == [2]);

auto sub = new ReplaySubject!int(2);
.put(sub, 1);
.put(sub, 2);
.put(sub, 3);

int[] buf;
auto d = sub.doSubscribe!(v => buf ~= v);
scope (exit)
    d.dispose();

assert(buf == [2, 3]);

ReplaySubject

Constructors

Members

Functions

Examples

Meta

Source