Subjects
function both as an Observer and as an Observable. Subjects inherit all Observable
functions, including subscribe. Values can also be pushed to the Subject
, which will be broadcasted to any subscribed Observers.cp.rx.Subject:onCompleted() -> nil
cp.rx.Subject:onError(message) -> nil
Observers
that an error has occurred.cp.rx.Subject:onNext(...) -> nil