abortSignal detached getJob getResult isJobActive makeJob must nativePromise restarting start task

defer next sleep timeout to until

action cached peek recalcWhen rule runRules until value

connect each forEach into next noop throttle

backpressure emitter empty fromAsyncIterable fromDomEvent fromIterable fromPromise fromSubscribe fromValue interval lazy mockSource never

compose concat concatAll concatMap filter map merge mergeAll mergeMap pipe share skip skipUntil skipWhile slack switchAll switchMap take takeUntil takeWhile

CancelResult ErrorResult ValueResult fulfillPromise isCancel isError isHandled isUnhandled isValue markHandled propagateResult reject rejecter resolve resolver

AnyFunction AsyncStart Backpressure CancelResult CleanupFn Configurable Connection DisposeFn Each EachResult Emitter ErrorResult GenericMethodDecorator HandledError Inlet IsStream Job JobIterator JobResult MockSource NextMethod Nothing OptionalCleanup PlainFunction RecalcSource Request RuleFactory Signal SignalSource Sink Source StartFn StartObj Stream Suspend SyncStart Throttle Transformer UnhandledError UntilMethod ValueResult Writable Yielding isFunction

CancelError CircularDependency WriteConflict