Internal use only. Do not use.
Life cycle handler, usually invoked automatically when a finite stream source is finished.
Error handler, which will be called to handle any uncaught errors while executing ISubscriber.next or a transducer function attached to the Subscription wrapping this subscriber. The error handler must return true to indicate the error could be successfully handled/recovered from. If false, the subscription will go into State.ERROR and stops processing any further values (plus might trigger recursive teardown of the upstream dataflow topology).
Syntax sugar for Subscription.transform when using a single map transducer only. The given function fn
is used as map
's transformation fn.
Receives new input value x
and executes any side effect.
Creates a new child subscription using given transducers and optional subscription ID. Supports up to 4 transducers and if more than one transducer is given, composes them in left-to-right order using {@link @thi.ng/transducers#(comp:1)}.
Shorthand for subscribe(comp(xf1, xf2,...), id)
Generated using TypeDoc
stream & reactive for reference & examples.