MCPcopy Create free account

hub / github.com/deanrad/rxfx / functions

Functions271 in github.com/deanrad/rxfx

⨍ Functions 271◇ Types & classes 57
↓ 284 callersFunctionafter
( delayArg: number | Promise<any> | typeof setTimeout, valueProvider?: T | ((v?: T) => T) | Observable<T>,
after/src/after.ts:69
↓ 151 callersMethodsubscribe
()
bus/src/bus.ts:272
↓ 108 callersMethodtrigger
* Puts an event onto the bus, firing any listeners whose predicate returns `true`. * Events go first through guards, then filters, then spies, then
bus/src/bus.ts:190
↓ 105 callersMethodnext
(v: MatchType)
bus/src/bus.ts:174
↓ 72 callersMethodrequest
Explicitly pass a request object
service/src/types.ts:172
↓ 49 callersFunctioncreateEffect
( handler: EffectSource<Request, Response>, concurrencyOperator = mergeMap, initialState?: TState )
effect/src/createEffect.ts:50
↓ 49 callersFunctioncreateServiceListener
( actionNamespace: string, bus: Bus<Action<TRequest | TNext | TError | void>>, handler: EventHandler<TRe
service/src/createService.ts:61
↓ 37 callersMethodlisten
Assigns a side-effect producing function to matching events in Concurrency Mode "Immediate". * Newly returned effects are begun immediately, and so
bus/src/bus.ts:250
↓ 32 callersMethodquery
* Returns an Observable of events for which the predicate returns `true`. * The returned Observable completes upon a `bus.reset`. * If the predi
bus/src/bus.ts:143
↓ 30 callersMethodcomplete
()
bus/src/bus.ts:273
↓ 30 callersMethodunsubscribe
()
bus/src/bus.ts:275
↓ 28 callersMethodadd
(tween: Tween<UnknownProps>)
animation/src/tweenjs/Group.ts:29
↓ 21 callersFunctionafter
( delaySpec: number | Promise<unknown> | typeof setTimeout, objOrFn?: T | Thunk<T> | Observable<T> )
operators/test/util/after.ts:17
↓ 21 callersFunctionmostRecentOf
(ary: T[])
service/test/createAsyncListService.spec.ts:9
↓ 20 callersMethodfilter
Run a function synchronously for all runtime events, after guards, and prior to spies and listeners. * A filter may modify, or replace an event. Ho
bus/src/bus.ts:419
↓ 19 callersMethodspy
Run a function (synchronously) for all runtime events, prior to all listeners. Throwing an exception will terminate the spy. * @returns A subscript
bus/src/bus.ts:437
↓ 18 callersMethoderror
()
bus/src/bus.ts:171
↓ 16 callersMethodreset
* Cancels current and queued effects, and returns the state to its initial value
service/src/types.ts:60
↓ 15 callersFunctioncreateEvent
(type: string)
fsa/src/createEvents.ts:26
↓ 14 callersFunctioncreateQueueingEffect
( handler: EffectSource<Request, Response>, initialState?: TState )
effect/src/createEffect.ts:308
↓ 13 callersMethodsend
Get a promise for the next response or error. Note: works best for a queueing service, otherwise may not be the response/error that was triggered by t
service/src/types.ts:165
↓ 13 callersFunctionuseService
( service: UsableAsService<TRequest, TState, TError, unknown>, options: UseServiceOptions = {} )
react/src/useService.ts:36
↓ 13 callersFunctionuseWhileMounted
(sourceFactory: SubscriptionFactory)
react/src/useWhileMounted.ts:25
↓ 11 callersMethodcancelCurrent
Cancels the current handling by triggering service.actions.cancel. * The effect is truly canceled if it was started from an Observable. * The ca
service/src/types.ts:41
↓ 11 callersMethodguard
Run a function synchronously for all runtime events, prior to all filters, spies and listeners. * Throwing an exception will raise to the triggerer
bus/src/bus.ts:397
↓ 10 callersFunctionmatchesAny
(...acs: ActionCreator<any>[])
service/src/createService.ts:25
↓ 9 callersFunctioncapturing
(bus: Bus<T>, testFn: (arg: T[]) => void | Promise<any>)
bus/test/bus.spec.ts:24
↓ 9 callersFunctioncreateService
( actionNamespace: string, handler: EventHandler<TRequest, TNext>, reducerProducer?: ReducerProducer<TRe
service/src/createService.ts:400
↓ 9 callersFunctionhandler
()
service/test/types.spec.ts:12
↓ 9 callersMethodstop
Terminates the listener, any of its Observable handlings. * @returns The closed subscription.
service/src/types.ts:36
↓ 8 callersFunctioneventsOf
(bus: Bus<T>)
service/test/createService.spec.ts:1514
↓ 7 callersMethodobserve
( callbacks: Partial<ProcessLifecycleCallbacks<Request, Response, Error>> )
effect/src/types.ts:79
↓ 6 callersFunctionoperatorForMode
(mode?: ConcurrencyMode)
service/src/createService.ts:34
↓ 6 callersMethodrequest
fire off a request
react/src/useService.ts:14
↓ 5 callersFunctionmakeAwaitable
( obs: Observable<T>, observer?: Partial<TapObserver<T>> )
after/src/after.ts:24
↓ 5 callersFunctionqueueOnlyLatest
( workCreator: (event: T) => ObservableInput<R>, mapper?: (_: T, inner: R) => S )
operators/src/queueOnlyLatest.ts:20
↓ 4 callersFunctionactionCreator
( type: string, commonMeta?: Meta, isError: ((payload: Payload) => boolean) | boolean = defaultIsE
fsa/src/typescript-fsa.ts:158
↓ 4 callersFunctioncreateQueueingServiceListener
( actionNamespace: string, bus: Bus<Action<TRequest | TNext | TError | void>>, handler: EventHandler<TRe
service/src/createService.ts:429
↓ 4 callersFunctioncreateReplacingServiceListener
( actionNamespace: string, bus: Bus<Action<TRequest | TNext | TError | void>>, handler: EventHandler<TRe
service/src/createService.ts:552
↓ 4 callersMethodgetId
()
animation/src/tweenjs/Tween.ts:52
↓ 4 callersFunctionmapper
(t: number, r: string)
operators/test/queueOnlyLatest.spec.ts:19
↓ 4 callersMethodobserveWith
Creates an {@link EffectObserver} which triggers the handlers' lifecycle events, after running through a mapping function. * Use this when the list
bus/src/bus.ts:471
↓ 4 callersFunctionpadToTime
(minimumMs: number)
operators/src/padToTime.ts:9
↓ 3 callersFunctionbecomesInactive
(activity: ActivityTracked)
bus/src/bus.ts:532
↓ 3 callersMethodcancelCurrentAndQueued
Cancels the current handling by triggering service.actions.cancel. * In addition, any operations enqueued will not be begun. (Safe to call even if
service/src/types.ts:45
↓ 3 callersFunctioncreateAsyncListService
( namespace: string = `list/${anonListCount++}`, delay: number = THRESHOLD.AnimationShort, finder: (obj1
service/src/createAsyncListService.ts:31
↓ 3 callersFunctioncreateCancelableEffect
()
react/src/__tests__/useService.test.ts:7
↓ 3 callersFunctioncreateProcessEvents
( ns: string )
fsa/src/createEvents.ts:36
↓ 3 callersMethodcreateRemovalSub
( matcher: Function, fn: Function, all: Array<[Predicate<EventType>, (item: EventType) => unknown]
bus/src/bus.ts:509
↓ 3 callersFunctioncreateTogglingServiceListener
( actionNamespace: string, bus: Bus<Action<TRequest | TNext | TError | void>>, handler: EventHandler<TRe
service/src/createService.ts:674
↓ 3 callersFunctionforward
( source: Observable<any>, matcher: Parameters<Bus<Action<Subtype>>['filter']>[0], sink: (v: MappedType)
peer/src/forward.ts:19
↓ 3 callersMethodlistenSwitching
Assigns a side-effect producing function to matching events in Concurrency Mode "Switching". * Any existing effect is canceled (if it is an Observa
bus/src/bus.ts:343
↓ 3 callersMethodnextEvent
* Returns a Promise for the first event for which the predicate returns `true`. * The returned Promise will be rejected upon a `bus.reset`. * If
bus/src/bus.ts:163
↓ 3 callersFunctionoutbox
(a: Action<any>)
peer/test/peer.spec.ts:10
↓ 3 callersMethodreset
()
effect/src/types.ts:83
↓ 3 callersMethodstart
(time: number = now())
animation/src/tweenjs/Tween.ts:83
↓ 3 callersFunctiontimeoutHandler
( opts: TimeoutOptions<TRequest, TError>, handler: (req: TRequest) => ObservableInput<TNext> // type of ar
service/src/modifyHandler.ts:27
↓ 3 callersFunctiontoggleMap
( workCreator: (event: T) => ObservableInput<R>, mapper?: (_: T, inner: R) => S )
operators/src/toggleMap.ts:26
↓ 3 callersFunctiontweenToValue
( startValue: Start, finalValue: End, duration: number, easing: (value: number) => number = Easing.Lin
animation/src/tweens.ts:10
↓ 2 callersMethod_swapEndStartRepeatValues
(property: string)
animation/src/tweenjs/Tween.ts:498
↓ 2 callersFunctionactionCreatorFactory
( prefix?: string | null, defaultIsError: (payload: any) => boolean = (p) => p instanceof Error )
fsa/src/typescript-fsa.ts:150
↓ 2 callersMethodaddTeardown
* Adds a function to be called only once when stop() is invoked
service/src/types.ts:55
↓ 2 callersMethodcompleteCurrent
Completes the current handling, triggering actions.complete. If a value for `final` is provided, * that is emitted via actions.next first. Useful t
service/src/types.ts:50
↓ 2 callersFunctioncreateImmediateEffect
( handler: EffectSource<Request, Response>, initialState?: TState )
effect/src/createEffect.ts:293
↓ 2 callersFunctioncreatePeer
( props: LeadPeerProps )
peer/src/peer.ts:45
↓ 2 callersFunctioncreateQueueingService
( actionNamespace: string, handler: EventHandler<TRequest, TNext>, reducerProducer?: ReducerProducer<TRe
service/src/createService.ts:461
↓ 2 callersFunctioncreateSwitchingServiceListener
( actionNamespace: string, bus: Bus<Action<TRequest | TNext | TError | void>>, handler: EventHandler<TRe
service/src/createService.ts:491
↓ 2 callersFunctiondebounceByPromise
(obs: Observable<T>)
operators/src/debounceByPromise.ts:7
↓ 2 callersFunctionevaluateFormula
(formula)
examples/7guis-cells/7-cells.js:15
↓ 2 callersFunctionexecutor
(req: Request)
effect/src/createEffect.ts:179
↓ 2 callersFunctiongetInitialState
( reducer: ServiceReducer<TRequest, TNext, TError, TState> )
service/src/createService.ts:157
↓ 2 callersFunctionmakeWork
(trigger: T)
operators/src/queueOnlyLatest.ts:46
↓ 2 callersMethodobserveAll
Creates an {@link EffectObserver} which triggers each value from the handler back onto the bus. * Use this when the listener returns items suitable
bus/src/bus.ts:451
↓ 2 callersFunctiononceInactive
()
service/src/createService.ts:100
↓ 2 callersFunctionpause
(duration: number)
after/src/after.ts:152
↓ 2 callersFunctionrandomizePreservingAverage
(duration: number)
perception/src/randomizer.ts:4
↓ 2 callersFunctionreducer
(state = initial, e)
service/test/types.spec.ts:14
↓ 2 callersMethodremove
(tween: Tween<UnknownProps>)
animation/src/tweenjs/Group.ts:34
↓ 2 callersMethodstopChainedTweens
()
animation/src/tweenjs/Tween.ts:256
↓ 2 callersFunctiontrace
( effect: EffectRunner<any, any, any, any>, prefix = 'rxfx', fn = console.log )
effect/src/createEffect.ts:457
↓ 2 callersMethodupdate
* @returns true if the tween is still playing after the update, false * otherwise (calling update on a paused tween still returns true because * i
animation/src/tweenjs/Tween.ts:342
↓ 2 callersFunctionuseAtUnmount
(unmountCallback: () => void)
react/src/useWhileMounted.ts:96
↓ 2 callersFunctionuseClosureListener
( args: ListenerArgs<TConsequence, TMatchType>, deps: any[] = [] )
react/src/useClosureHandlers.ts:29
↓ 2 callersFunctionuseStableCallback
(producer: (...args: any[]) => T)
react/src/stabilityHooks.ts:9
↓ 2 callersFunctionwithTiming
(events)
bus/test/bus.spec.ts:40
↓ 1 callersMethod_handleRelativeValue
(start: number, end: number | string)
animation/src/tweenjs/Tween.ts:486
↓ 1 callersMethod_setupProperties
( _object: UnknownProps, _valuesStart: UnknownProps, _valuesEnd: UnknownProps, _valuesStartRepeat: Unk
animation/src/tweenjs/Tween.ts:122
↓ 1 callersMethod_updateProperties
( _object: UnknownProps, _valuesStart: UnknownProps, _valuesEnd: UnknownProps, value: number, )
animation/src/tweenjs/Tween.ts:448
↓ 1 callersMethodcancelCurrent
cancel only the in-flight request
react/src/useService.ts:16
↓ 1 callersMethodcancelCurrentAndQueued
cancel in-flight + queued requests
react/src/useService.ts:18
↓ 1 callersFunctionconvertSlayToJest
(spec: SlayItem)
examples/slayr/convert/jest-emitter.ts:84
↓ 1 callersFunctioncreateBlockingEffect
( handler: EffectSource<Request, Response>, initialState?: TState )
effect/src/createEffect.ts:339
↓ 1 callersFunctioncreateBlockingServiceListener
( actionNamespace: string, bus: Bus<Action<TRequest | TNext | TError | void>>, handler: EventHandler<TRe
service/src/createService.ts:611
↓ 1 callersFunctioncreateCustomEffect
( handler: EffectSource<Request, Response>, concurrencyOperator = mergeMap, initialState?: TState )
effect/src/createEffect.ts:439
↓ 1 callersFunctioncreateDebouncedEffect
( msec: number = DEFAULT_DEBOUNCE_INTERVAL )
effect/src/createEffect.ts:408
↓ 1 callersFunctioncreateRequestMergeReducer
(initialState: TNext)
service/src/reducers.ts:37
↓ 1 callersFunctioncreateResponseMergeReducer
(initialState: TNext)
service/src/reducers.ts:20
↓ 1 callersFunctioncreateResponseReducer
(initialState: TNext)
service/src/reducers.ts:6
↓ 1 callersFunctioncreateSwitchingEffect
( handler: EffectSource<Request, Response>, initialState?: TState )
effect/src/createEffect.ts:323
↓ 1 callersFunctioncreateThrottledEffect
( msec: number = DEFAULT_DEBOUNCE_INTERVAL )
effect/src/createEffect.ts:375
next →1–100 of 271, ranked by callers