MCPcopy Create free account

hub / github.com/ReactiveX/rxjs / functions

Functions1,267 in github.com/ReactiveX/rxjs

↓ 2 callersFunctionK
(a,d)
apps/rxjs.dev/src/assets/js/prettify.js:31
↓ 2 callersFunctionL
(a,d,f)
apps/rxjs.dev/src/assets/js/prettify.js:29
↓ 2 callersFunctionM
(a)
apps/rxjs.dev/src/assets/js/prettify.js:32
↓ 2 callersMethod_checkFinalizedStatuses
@internal
packages/rxjs/src/internal/Subject.ts:122
↓ 2 callersMethod_execute
(state: T, _delay: number)
packages/rxjs/src/internal/scheduler/AsyncAction.ts:114
↓ 2 callersMethod_innerSubscribe
@internal
packages/rxjs/src/internal/Subject.ts:105
↓ 2 callersMethod_trimBuffer
()
packages/rxjs/src/internal/ReplaySubject.ts:86
↓ 2 callersFunctionanimationFrames
(timestampProvider?: TimestampProvider)
packages/rxjs/src/internal/observable/dom/animationFrames.ts:75
↓ 2 callersFunctionanimationFramesFactory
* Does the work of creating the observable for `animationFrames`. * @param timestampProvider The timestamp provider to use to create the observable
packages/rxjs/src/internal/observable/dom/animationFrames.ts:83
↓ 2 callersFunctionarrayOrObject
(first: T | T[] | O)
packages/rxjs/src/internal/util/argsArgArrayOrObject.ts:22
↓ 2 callersFunctionbindCallback
( callbackFunc: (...args: [...any[], (...res: any) => void]) => void, resultSelector?: ((...args: any[]) =
packages/rxjs/src/internal/observable/bindCallback.ts:143
↓ 2 callersFunctionbindCallbackInternals
( isNodeStyle: boolean, callbackFunc: any, resultSelector?: any, scheduler?: SchedulerLike )
packages/rxjs/src/internal/observable/bindCallbackInternals.ts:8
↓ 2 callersFunctionbuffer
(closingNotifier: ObservableInput<any>)
packages/rxjs/src/internal/operators/buffer.ts:43
↓ 2 callersFunctionbufferCount
(bufferSize: number, startBufferEvery: number | null = null)
packages/rxjs/src/internal/operators/bufferCount.ts:56
↓ 2 callersFunctionbufferTime
(bufferTimeSpan: number, ...otherArgs: any[])
packages/rxjs/src/internal/operators/bufferTime.ts:73
↓ 2 callersFunctionbufferToggle
( openings: ObservableInput<O>, closingSelector: (value: O) => ObservableInput<any> )
packages/rxjs/src/internal/operators/bufferToggle.ts:49
↓ 2 callersFunctionbufferWhen
(closingSelector: () => ObservableInput<any>)
packages/rxjs/src/internal/operators/bufferWhen.ts:44
↓ 2 callersFunctionbuild
(apiList: FlattenedApiList, tree: TreeNodeRaw[], log: { warn: (message: string) => void })
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/build.ts:17
↓ 2 callersMethodcalculateTop
(scrollTop: number, topOffset: number)
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:46
↓ 2 callersFunctioncancelReset
()
packages/rxjs/src/internal/operators/share.ts:150
↓ 2 callersFunctioncheckComplete
()
packages/rxjs/src/internal/operators/repeatWhen.ts:52
↓ 2 callersFunctioncheckComplete
()
packages/rxjs/src/internal/operators/mergeInternals.ts:41
↓ 2 callersFunctionclearInterval
(handle)
packages/rxjs/src/internal/scheduler/intervalProvider.ts:26
↓ 2 callersFunctioncloseWindow
(record: { window: Subject<T>; subs: Subscription })
packages/rxjs/src/internal/operators/windowTime.ts:116
↓ 2 callersFunctioncombineLatestAll
(project?: (...values: Array<any>) => R)
packages/rxjs/src/internal/operators/combineLatestAll.ts:48
↓ 2 callersFunctioncombineLatestInit
(observables: ObservableInput<any>[], valueTransform: (values: any[]) => any = identity)
packages/rxjs/src/internal/observable/combineLatest.ts:196
↓ 2 callersFunctioncombineLatestWith
( ...otherSources: [...ObservableInputTuple<A>] )
packages/rxjs/src/internal/operators/combineLatestWith.ts:45
↓ 2 callersMethodcomplete
()
packages/rxjs/src/internal/AsyncSubject.ts:31
↓ 2 callersFunctionconcatMapTo
(innerObservable: O)
packages/rxjs/src/internal/operators/concatMapTo.ts:60
↓ 2 callersFunctionconnect
( selector: (shared: Observable<T>) => O, config: ConnectConfig<T> = DEFAULT_CONFIG )
packages/rxjs/src/internal/operators/connect.ts:97
↓ 2 callersMethodcreate
(worker: Worker, zone: NgZone)
apps/rxjs.dev/src/app/shared/web-worker.ts:14
↓ 2 callersFunctioncreateBindingInfo
(propertyName, bindingName)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/matchUpDirectiveDecorators.js:80
↓ 2 callersFunctioncreateFind
( predicate: (value: T, index: number, source: Observable<T>) => boolean, emit: 'value' | 'index', sourc
packages/rxjs/src/internal/operators/find.ts:54
↓ 2 callersFunctioncreateLinkNode
(doc, text)
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:147
↓ 2 callersFunctioncreateObject
(keys: string[], values: any[])
packages/rxjs/src/internal/util/createObject.ts:1
↓ 2 callersFunctioncreateOpenMatcher
(elementNameMatcher)
apps/rxjs.dev/tools/transforms/remark-package/services/renderMarkdown.js:202
↓ 2 callersFunctioncreateResponse
(direction: AjaxDirection, event: ProgressEvent)
packages/rxjs/src/internal/ajax/ajax.ts:435
↓ 2 callersFunctiondebounce
(durationSelector: (value: T) => ObservableInput<any>)
packages/rxjs/src/internal/operators/debounce.ts:64
↓ 2 callersFunctiondecisionTreeReducer
(tree: TreeNode[], apiList: FlattenedApiList, log: { warn: (message: string) => void })
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/decisionTreeReducer.ts:12
↓ 2 callersFunctiondefaultIfEmpty
(defaultValue: R)
packages/rxjs/src/internal/operators/defaultIfEmpty.ts:39
↓ 2 callersFunctiondematerialize
()
packages/rxjs/src/internal/operators/dematerialize.ts:53
↓ 2 callersFunctiondistinctUntilKeyChanged
( key: K, compare?: (x: T[K], y: T[K]) => boolean )
packages/rxjs/src/internal/operators/distinctUntilKeyChanged.ts:70
↓ 2 callersFunctiondoPrepareTitleAndToc
(contents: string, docId = '')
apps/rxjs.dev/src/app/layout/doc-viewer/doc-viewer.component.spec.ts:127
↓ 2 callersMethoddoSearch
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:51
↓ 2 callersFunctionelementAt
(index: number, defaultValue?: D)
packages/rxjs/src/internal/operators/elementAt.ts:54
↓ 2 callersFunctionemit
(record: { buffer: T[]; subs: Subscription })
packages/rxjs/src/internal/operators/bufferTime.ts:92
↓ 2 callersFunctionendWith
(...values: A)
packages/rxjs/src/internal/operators/endWith.ts:52
↓ 2 callersFunctionevery
( predicate: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any )
packages/rxjs/src/internal/operators/every.ts:42
↓ 2 callersFunctionexecFinalizer
(finalizer: Unsubscribable | (() => void))
packages/rxjs/src/internal/Observable.ts:192
↓ 2 callersFunctionexhaustAll
()
packages/rxjs/src/internal/operators/exhaustAll.ts:49
↓ 2 callersFunctionexpand
( project: (value: T, index: number) => O, concurrent = Infinity, scheduler?: SchedulerLike )
packages/rxjs/src/internal/operators/expand.ts:71
↓ 2 callersFunctionextractInitialSequence
(tree: TreeNode[])
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/extractInitialSequence.ts:10
↓ 2 callersMethodfetchSections
* Fetch API sections from a JSON file. * API sections is an array of Angular top modules and metadata about their API documents (items). * Updates
apps/rxjs.dev/src/app/custom-elements/api/api.service.ts:72
↓ 2 callersFunctionfind
(predicate: (value: T, index: number, source: Observable<T>) => boolean)
packages/rxjs/src/internal/operators/find.ts:50
↓ 2 callersFunctionfindAndClearHandle
* Finds the handle in the list of active handles, and removes it. * Returns `true` if found, `false` otherwise. Used both to clear * Immediate sched
packages/rxjs/src/internal/util/Immediate.ts:11
↓ 2 callersFunctionfindIndex
(predicate: (value: T, index: number, source: Observable<T>) => boolean)
packages/rxjs/src/internal/operators/findIndex.ts:49
↓ 2 callersFunctionflattenApiList
(apiList: ApiListNode[])
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/flattenApiList.ts:14
↓ 2 callersMethodfocus
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:59
↓ 2 callersFunctionforkJoin
(...args: any[])
packages/rxjs/src/internal/observable/forkJoin.ts:144
↓ 2 callersMethodformatDisplayedCode
()
apps/rxjs.dev/src/app/custom-elements/code/code.component.ts:133
↓ 2 callersFunctionfoundValidDoc
* Validates the docs to be used to generate the links. The validation ensures * that the docs are not `internal` and that the `docType` is supporte
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:119
↓ 2 callersFunctionfromArrayLike
(array: ArrayLike<T>)
packages/rxjs/src/internal/Observable.ts:1149
↓ 2 callersFunctionfromAsyncIterable
(asyncIterable: AsyncIterable<T>)
packages/rxjs/src/internal/Observable.ts:1183
↓ 2 callersFunctionfromFetch
( input: string | Request, initWithSelector: RequestInit & { selector?: (response: Response) => Observ
packages/rxjs/src/internal/observable/dom/fetch.ts:93
↓ 2 callersFunctionfromPromise
(promise: PromiseLike<T>)
packages/rxjs/src/internal/Observable.ts:1155
↓ 2 callersFunctiongenerateUniqueId
()
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/generateUniqueId.ts:10
↓ 2 callersMethodgetAllResponseHeaders
()
packages/rxjs/spec/observables/dom/ajax-spec.ts:1643
↓ 2 callersFunctiongetAnchors
()
apps/rxjs.dev/src/app/custom-elements/live-example/live-example.component.spec.ts:28
↓ 2 callersFunctiongetApiSections
()
apps/rxjs.dev/src/app/custom-elements/api/api-list.component.spec.ts:287
↓ 2 callersMethodgetContentHeight
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:164
↓ 2 callersMethodgetCurrentHash
* Return the hash fragment from the `PlatformLocation`, minus the leading `#`.
apps/rxjs.dev/src/app/shared/scroll.service.ts:201
↓ 2 callersMethodgetDecisionTree$
()
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/operator-decision-tree-data.service.ts:10
↓ 2 callersMethodgetDocument
(url: string)
apps/rxjs.dev/src/app/documents/document.service.ts:46
↓ 2 callersFunctiongetFilteredDocsFromAlias
(words, index)
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:84
↓ 2 callersMethodgetJSON
* Performs an HTTP GET using the * [XMLHttpRequest](https://developer.mozilla.org/en-US/docs/Web/API/XMLHttpRequest) in * global scope by defaul
packages/rxjs/src/internal/ajax/ajax.ts:135
↓ 2 callersFunctiongetObservableInputType
(input: unknown)
packages/rxjs/src/internal/Observable.ts:1240
↓ 2 callersMethodgetTopOffset
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:172
↓ 2 callersFunctiongroupBy
( keySelector: (value: T) => K, elementOrOptions?: ((value: any) => any) | void | BasicGroupByOptions<K, T
packages/rxjs/src/internal/operators/groupBy.ts:138
↓ 2 callersMethodhandleAnchorClick
* Handle user's anchor click * * @param anchor {HTMLAnchorElement} - the anchor element clicked * @param button Number of the mouse button he
apps/rxjs.dev/src/app/shared/location.service.ts:114
↓ 2 callersFunctionhandleError
(err: any)
packages/rxjs/src/internal/operators/groupBy.ts:164
↓ 2 callersMethodhandleError
(error: ErrorEvent)
apps/rxjs.dev/src/app/shared/web-worker.ts:34
↓ 2 callersFunctionhandler
(arg: any)
packages/rxjs/spec/observables/from-spec.ts:279
↓ 2 callersMethodhideSearchResults
()
apps/rxjs.dev/src/app/app.component.ts:461
↓ 2 callersFunctioniif
(condition: () => boolean, trueResult: ObservableInput<T>, falseResult: ObservableInput<F>)
packages/rxjs/src/internal/observable/iif.ts:83
↓ 2 callersFunctioninteropSubscribe
(subscribe: (...args: any[]) => Subscription)
packages/rxjs/spec/helpers/interop-helper.ts:55
↓ 2 callersFunctionisArrayLike
(x: any)
packages/rxjs/src/internal/Observable.ts:1320
↓ 2 callersFunctionisEmpty
()
packages/rxjs/src/internal/operators/isEmpty.ts:65
↓ 2 callersFunctionisEventTarget
* Checks to see if the target implements the required EventTarget methods * for adding and removing event handlers. * @param target the object to ch
packages/rxjs/src/internal/observable/fromEvent.ts:329
↓ 2 callersFunctionisInitialDecision
(previousBranchIds: string[])
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/utils.ts:3
↓ 2 callersFunctionisInsideLink
(ancestors)
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:80
↓ 2 callersFunctionisJQueryStyleEventEmitter
* Checks to see if the target implements the required jQuery-style EventEmitter methods * for adding and removing event handlers. * @param target th
packages/rxjs/src/internal/observable/fromEvent.ts:320
↓ 2 callersMethodisLocationWithHash
* test if the current location has a hash
apps/rxjs.dev/src/app/shared/scroll.service.ts:94
↓ 2 callersFunctionisNodeStyleEventEmitter
* Checks to see if the target implements the required node-style EventEmitter methods * for adding and removing event handlers. * @param target the
packages/rxjs/src/internal/observable/fromEvent.ts:311
↓ 2 callersFunctionisPromise
(value: any)
packages/rxjs/src/internal/Observable.ts:1306
↓ 2 callersFunctionisStable
(stability: string)
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/helpers.ts:14
↓ 2 callersFunctionjoinAllInternals
(joinFn: (sources: ObservableInput<T>[]) => Observable<T>, project?: (...args: any[]) => R)
packages/rxjs/src/internal/operators/joinAllInternals.ts:19
↓ 2 callersFunctionlast
( predicate?: ((value: T, index: number, source: Observable<T>) => boolean) | null, defaultValue?: D )
packages/rxjs/src/internal/operators/last.ts:75
↓ 2 callersFunctionlastValueFrom
(source: Observable<T>, config?: LastValueFromConfig<D>)
packages/rxjs/src/internal/lastValueFrom.ts:54
↓ 2 callersMethodloadContainedCustomElements
* Queries the provided element for any custom elements that have not yet been registered with * the browser. Custom elements that are registered wi
apps/rxjs.dev/src/app/custom-elements/elements-loader.ts:33
↓ 2 callersMethodlocationChanged
(url: string)
apps/rxjs.dev/src/app/shared/ga.service.ts:20
← previousnext →201–300 of 1,267, ranked by callers