Subject Guide

Subject

Stream Subject

Stream subjects can multicast events to multiple observers.

Stream.Subject s = new Stream.Subject();
s.subscribe(R.debug.apply('No.1'));
s.subscribe(R.debug.apply('No.2'));

s.next(1);
s.next(2);

// No.1, 1
// No.2, 1
// No.1, 2
// No.2, 2

Methods

MethodDescription
Subject()Create a default subject
next(Object)Send the next event
error(Object)Send the error event
complete()Send the complete event

Contribute on Github! Edit this section.