Subject.md

com.industry.rx_epl.Subject <>

A simple subject that allows values to be sent to all subscribers.

Constructors

• Create

# static .create() returns ISubject <>

Creates a new Subject.

ISubject s := Subject.create();

ISubscription sub1 := s.subscribe(...);
s.next("Value1"); // Output (from sub1): "Value1"

ISubscription sub2 := s.subscribe(...);
s.next("Value2"); // Output (from sub1 and sub2): "Value2"

sub1.dispose();
s.next("Value3"); // Output (from sub2): "Value3"

s.complete(); // sub2 terminates (calling it's onComplete)