MCPcopy Create free account

hub / github.com/ReactiveX/rxjs / functions

Functions1,267 in github.com/ReactiveX/rxjs

⨍ Functions 1,267◇ Types & classes 499
↓ 5 callersFunctioncallback
()
packages/rxjs/spec/operators/shareReplay-spec.ts:349
↓ 5 callersFunctionconcatAll
()
packages/rxjs/src/internal/operators/concatAll.ts:60
↓ 5 callersFunctiondebounceTime
(dueTime: number, scheduler: SchedulerLike = asyncScheduler)
packages/rxjs/src/internal/operators/debounceTime.ts:63
↓ 5 callersMethoddispatchEvent
(event: ProgressEvent)
packages/rxjs/spec/observables/dom/ajax-spec.ts:1543
↓ 5 callersFunctiondistinctUntilChanged
( comparator?: (previous: K, current: K) => boolean, keySelector: (value: T) => K = identity as (value: T)
packages/rxjs/src/internal/operators/distinctUntilChanged.ts:138
↓ 5 callersMethodexecute
(state: T, delay: number)
packages/rxjs/src/internal/scheduler/QueueAction.ts:22
↓ 5 callersFunctionignoreElements
()
packages/rxjs/src/internal/operators/ignoreElements.ts:40
↓ 5 callersFunctionlowerCaseO
(...args: Array<any>)
packages/rxjs/spec/helpers/test-helper.ts:18
↓ 5 callersFunctionmapOneOrManyArgs
(fn: (...values: T[]) => R)
packages/rxjs/src/internal/util/mapOneOrManyArgs.ts:14
↓ 5 callersFunctionobserveOn
(scheduler: SchedulerLike, delay = 0)
packages/rxjs/src/internal/operators/observeOn.ts:57
↓ 5 callersFunctionpipe
(...fns: Array<UnaryFunction<any, any>>)
packages/rxjs/src/internal/util/pipe.ts:77
↓ 5 callersFunctionproject
(x: number)
packages/rxjs/spec/operators/expand-spec.ts:423
↓ 5 callersMethodsearch
* Search the index using the given query and emit results on the observable that is returned. * * @param query The query to run against the inde
apps/rxjs.dev/src/app/search/search.service.ts:50
↓ 5 callersFunctionsubscribeOn
(scheduler: SchedulerLike, delay: number = 0)
packages/rxjs/src/internal/operators/subscribeOn.ts:63
↓ 5 callersMethodtext
()
apps/rxjs.dev/src/app/layout/doc-viewer/dt.component.ts:24
↓ 5 callersMethodunsubscribe
()
packages/rxjs/src/internal/Observable.ts:354
↓ 4 callersFunctionaddUniqueId
(tree: TreeNodeRaw[], depth = 0)
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/addUniqueId.ts:15
↓ 4 callersFunctionargsOrArgArray
(args: (T | T[])[])
packages/rxjs/src/internal/util/argsOrArgArray.ts:7
↓ 4 callersFunctionasInteropSubscriber
(subscriber: Subscriber<T>)
packages/rxjs/spec/helpers/interop-helper.ts:43
↓ 4 callersFunctionboolFromValue
(attrValue: string | undefined, def: boolean = false)
apps/rxjs.dev/src/app/shared/attribute-utils.ts:42
↓ 4 callersFunctioncreateNotification
(kind: 'N' | 'E' | 'C', value: T | undefined, error: any)
packages/rxjs/src/internal/Observable.ts:1374
↓ 4 callersFunctionf
(e)
apps/rxjs.dev/src/assets/js/prettify.js:18
↓ 4 callersFunctionfromEvent
( target: any, eventName: string | symbol, options?: EventListenerOptions | ((...args: any[]) => T), r
packages/rxjs/src/internal/observable/fromEvent.ts:241
↓ 4 callersMethodgetValue
()
packages/rxjs/src/internal/BehaviorSubject.ts:24
↓ 4 callersFunctionisScheduler
(value: any)
packages/rxjs/src/internal/util/isScheduler.ts:4
↓ 4 callersFunctionmaterialize
()
packages/rxjs/src/internal/operators/materialize.ts:52
↓ 4 callersMethodparseMarblesAsSubscriptions
(marbles: string | null, runMode = false)
packages/rxjs/src/internal/testing/TestScheduler.ts:226
↓ 4 callersMethodpath
(path: string)
apps/rxjs.dev/src/app/custom-elements/code/code-example.component.ts:54
↓ 4 callersFunctionpopScheduler
(args: any[])
packages/rxjs/src/internal/util/args.ts:13
↓ 4 callersMethodremove
* Removes a finalizer from this subscription that was previously added with the {@link #add} method. * * Note that `Subscription` instances, whe
packages/rxjs/src/internal/Observable.ts:176
↓ 4 callersFunctionrepeat
(countOrConfig?: number | RepeatConfig)
packages/rxjs/src/internal/operators/repeat.ts:114
↓ 4 callersMethodscrollToTop
Scroll to the top of the document.
apps/rxjs.dev/src/app/shared/scroll.service.ts:155
↓ 4 callersMethodsearch
()
apps/rxjs.dev/src/app/custom-elements/api/api-list.component.spec.ts:212
↓ 4 callersMethodsetSearch
(label: string, params: { [key: string]: string|undefined})
apps/rxjs.dev/src/app/shared/location.service.ts:82
↓ 4 callersMethodtriggerEvent
(this: any, name: any, eventObj?: any)
packages/rxjs/spec/observables/dom/ajax-spec.ts:1717
↓ 4 callersFunctionzip
(...args: unknown[])
packages/rxjs/src/internal/observable/zip.ts:51
↓ 3 callersMethod_clearObservers
()
packages/rxjs/src/internal/Subject.ts:49
↓ 3 callersMethod_resetState
()
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:191
↓ 3 callersMethodabort
()
packages/rxjs/spec/observables/dom/ajax-spec.ts:1619
↓ 3 callersFunctionaudit
(durationSelector: (value: T) => ObservableInput<any>)
packages/rxjs/src/internal/operators/audit.ts:50
↓ 3 callersFunctionauditTime
(duration: number, scheduler: SchedulerLike = asyncScheduler)
packages/rxjs/src/internal/operators/auditTime.ts:53
↓ 3 callersFunctionb
(e)
apps/rxjs.dev/src/assets/js/prettify.js:18
↓ 3 callersMethodback
()
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/operator-decision-tree.service.ts:79
↓ 3 callersMethodcalibrate
(scrollTop: number, topOffset: number)
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:82
↓ 3 callersMethodcancelAnimationFrame
(handle: number)
packages/rxjs/src/internal/testing/TestScheduler.ts:463
↓ 3 callersFunctioncount
(predicate?: (value: T, index: number) => boolean)
packages/rxjs/src/internal/operators/count.ts:59
↓ 3 callersFunctiondelayWhen
( delayDurationSelector: (value: T, index: number) => ObservableInput<any>, subscriptionDelay?: Observable
packages/rxjs/src/internal/operators/delayWhen.ts:92
↓ 3 callersFunctiondistinct
(keySelector?: (value: T) => K, flushes?: ObservableInput<any>)
packages/rxjs/src/internal/operators/distinct.ts:62
↓ 3 callersFunctiondurationSelector
()
packages/rxjs/spec/operators/audit-spec.ts:332
↓ 3 callersFunctionexhaustMap
( project: (value: T, index: number) => O )
packages/rxjs/src/internal/operators/exhaustMap.ts:48
↓ 3 callersFunctionfirstValueFrom
(source: Observable<T>, config?: FirstValueFromConfig<D>)
packages/rxjs/src/internal/firstValueFrom.ts:56
↓ 3 callersMethodflush
(action?: AsyncAction<any>)
packages/rxjs/src/internal/scheduler/AsapScheduler.ts:5
↓ 3 callersMethodga
(...args: any[])
apps/rxjs.dev/src/app/shared/ga.service.ts:36
↓ 3 callersMethodgenToc
(docElement?: Element, docId = '')
apps/rxjs.dev/src/app/shared/toc.service.ts:23
↓ 3 callersFunctiongetAttrs
(el: HTMLElement | ElementRef)
apps/rxjs.dev/src/app/shared/attribute-utils.ts:14
↓ 3 callersFunctiongetDocFromAlias
(alias, originatingDoc)
apps/rxjs.dev/tools/transforms/links-package/services/getDocFromAlias.js:15
↓ 3 callersMethodgetScrollTop
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:168
↓ 3 callersFunctionhandleStoppedNotification
* A handler for notifications that cannot be sent to a stopped subscriber. * @param notification The notification being sent. * @param subscriber Th
packages/rxjs/src/internal/Observable.ts:498
↓ 3 callersMethodhideOptions
()
apps/rxjs.dev/src/app/shared/select/select.component.ts:59
↓ 3 callersFunctionisValidDate
(value: any)
packages/rxjs/src/internal/util/isDate.ts:8
↓ 3 callersFunctionkeySelector
(x: number)
packages/rxjs/spec/operators/distinctUntilChanged-spec.ts:247
↓ 3 callersFunctionlast
(arr: T[])
packages/rxjs/src/internal/util/args.ts:5
↓ 3 callersMethodloadCustomElement
Loads and registers the custom element defined on the `WithCustomElement` module factory.
apps/rxjs.dev/src/app/custom-elements/elements-loader.ts:45
↓ 3 callersFunctionmakeId
(title: string)
apps/rxjs.dev/src/app/custom-elements/resource/resource.service.ts:80
↓ 3 callersFunctionmergeInternals
( source: Observable<T>, destination: Subscriber<R>, project: (value: T, index: number) => ObservableInp
packages/rxjs/src/internal/operators/mergeInternals.ts:19
↓ 3 callersMethodmostRecent
()
packages/rxjs/spec/observables/dom/ajax-spec.ts:1559
↓ 3 callersMethodnext
(value: T)
packages/rxjs/src/internal/AsyncSubject.ts:24
↓ 3 callersFunctionobserveNotification
(notification: ObservableNotification<T>, observer: PartialObserver<T>)
packages/rxjs/src/internal/Notification.ts:10
↓ 3 callersFunctiononErrorResumeNextWith
( ...sources: [[...ObservableInputTuple<A>]] | [...ObservableInputTuple<A>] )
packages/rxjs/src/internal/operators/onErrorResumeNextWith.ts:84
↓ 3 callersMethodonResize
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:185
↓ 3 callersFunctionpopResultSelector
(args: any[])
packages/rxjs/src/internal/util/args.ts:9
↓ 3 callersFunctionrace
(...sources: (ObservableInput<T> | ObservableInput<T>[])[])
packages/rxjs/src/internal/observable/race.ts:48
↓ 3 callersMethodrecycleAsyncId
(_scheduler: AsyncScheduler, id?: TimerHandle, delay: number | null = 0)
packages/rxjs/src/internal/scheduler/AsyncAction.ts:70
↓ 3 callersMethodrender
* Add doc content to host element and build it out with embedded components.
apps/rxjs.dev/src/app/layout/doc-viewer/doc-viewer.component.ts:136
↓ 3 callersFunctionrepeatWhen
(notifier: (notifications: Observable<void>) => ObservableInput<any>)
packages/rxjs/src/internal/operators/repeatWhen.ts:40
↓ 3 callersFunctionreportUnhandledError
(err: any)
packages/rxjs/src/internal/Observable.ts:1023
↓ 3 callersMethodrequestAnimationFrame
(callback: FrameRequestCallback)
packages/rxjs/src/internal/testing/TestScheduler.ts:455
↓ 3 callersFunctionrequireFolder
(dirname, folderPath)
apps/rxjs.dev/tools/transforms/config.js:17
↓ 3 callersFunctionrx
(source: ObservableInput<unknown>, ...fns: UnaryFunction<any, unknown>[])
packages/rxjs/src/internal/util/rx.ts:115
↓ 3 callersFunctionsample
(notifier: ObservableInput<any>)
packages/rxjs/src/internal/operators/sample.ts:45
↓ 3 callersMethodscroll
* Scroll to the element with id extracted from the current location hash fragment. * Scroll to top if no hash. * Don't scroll if hash not found.
apps/rxjs.dev/src/app/shared/scroll.service.ts:83
↓ 3 callersMethodscrollToElement
* Scroll to the element. * Don't scroll if no element.
apps/rxjs.dev/src/app/shared/scroll.service.ts:134
↓ 3 callersFunctionselector
(x: string, y: number)
packages/rxjs/spec/observables/zip-spec.ts:203
↓ 3 callersFunctionsend
()
packages/rxjs/src/internal/operators/throttle.ts:107
↓ 3 callersMethodsend
(data: string)
packages/rxjs/spec/observables/dom/webSocket-spec.ts:777
↓ 3 callersMethodsetSearchCriteria
(criteria: SearchCriteria)
apps/rxjs.dev/src/app/custom-elements/api/api-list.component.ts:176
↓ 3 callersFunctionshareReplay
( configOrBufferSize?: ShareReplayConfig | number, windowTime?: number, scheduler?: SchedulerLike )
packages/rxjs/src/internal/operators/shareReplay.ts:154
↓ 3 callersFunctionsubscribeToArray
(array: ArrayLike<T>, subscriber: Subscriber<T>)
packages/rxjs/src/internal/Observable.ts:1210
↓ 3 callersMethodswapViews
* Swap the views, removing `currViewContainer` and inserting `nextViewContainer`. * (At this point all content should be ready, including having lo
apps/rxjs.dev/src/app/layout/doc-viewer/doc-viewer.component.ts:180
↓ 3 callersFunctionthrottle
(durationSelector: (value: T) => ObservableInput<any>, config?: ThrottleConfig)
packages/rxjs/src/internal/operators/throttle.ts:81
↓ 3 callersFunctiontimeout
( config: number | Date | TimeoutConfig<T, O, M>, schedulerArg?: SchedulerLike )
packages/rxjs/src/internal/operators/timeout.ts:279
↓ 3 callersFunctiontoStringCheck
(obj: any, name: string)
packages/rxjs/src/internal/ajax/ajax.ts:579
↓ 3 callersFunctiontrigger
(...args: any[])
packages/rxjs/spec/observables/fromEventPattern-spec.ts:84
↓ 3 callersMethodtrigger
(this: any, name: string, e: any)
packages/rxjs/spec/observables/dom/webSocket-spec.ts:816
↓ 3 callersMethodunspy
(spiedGroup: ScrollSpiedElementGroup)
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:221
↓ 3 callersFunctionwindow
(windowBoundaries: ObservableInput<any>)
packages/rxjs/src/internal/operators/window.ts:50
↓ 3 callersFunctionwithLatestFrom
(...inputs: any[])
packages/rxjs/src/internal/operators/withLatestFrom.ts:57
↓ 2 callersMethod#closeSocket
()
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:358
↓ 2 callersMethod#outputError
(err: any)
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:244
↓ 2 callersFunctionG
(a,d)
apps/rxjs.dev/src/assets/js/prettify.js:23
← previousnext →101–200 of 1,267, ranked by callers