cp.rx.RelaySubject.create([n]) -> cp.rx.RelaySubject
ReplaySubject
.nil
, an infinite buffer is used (note that this could lead to memory issues).cp.rx.RelaySubject:onNext(...) -> nil
cp.rx.RelaySubject:subscribe([observer | onNext[, onError[, onCompleted]]]) -> cp.rx.Reference
| | -----------------------------------------------------|---------------------------------------------------------------------------------------------------------| | Type | Method | | Description | Creates a new Observer and attaches it to the ReplaySubject
. | | Parameters |function
to call when the ReplaySubject
produces a value.function
to call when the ReplaySubject
terminates due to an error.function
to call when the ReplaySubject completes normally.