Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ReactiveX/rxjs
/ functions
Functions
1,267 in github.com/ReactiveX/rxjs
⨍
Functions
1,267
◇
Types & classes
499
↓ 2 callers
Function
K
(a,d)
apps/rxjs.dev/src/assets/js/prettify.js:31
↓ 2 callers
Function
L
(a,d,f)
apps/rxjs.dev/src/assets/js/prettify.js:29
↓ 2 callers
Function
M
(a)
apps/rxjs.dev/src/assets/js/prettify.js:32
↓ 2 callers
Method
_checkFinalizedStatuses
@internal
packages/rxjs/src/internal/Subject.ts:122
↓ 2 callers
Method
_execute
(state: T, _delay: number)
packages/rxjs/src/internal/scheduler/AsyncAction.ts:114
↓ 2 callers
Method
_innerSubscribe
@internal
packages/rxjs/src/internal/Subject.ts:105
↓ 2 callers
Method
_trimBuffer
()
packages/rxjs/src/internal/ReplaySubject.ts:86
↓ 2 callers
Function
animationFrames
(timestampProvider?: TimestampProvider)
packages/rxjs/src/internal/observable/dom/animationFrames.ts:75
↓ 2 callers
Function
animationFramesFactory
* 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 callers
Function
arrayOrObject
(first: T | T[] | O)
packages/rxjs/src/internal/util/argsArgArrayOrObject.ts:22
↓ 2 callers
Function
bindCallback
( callbackFunc: (...args: [...any[], (...res: any) => void]) => void, resultSelector?: ((...args: any[]) =
packages/rxjs/src/internal/observable/bindCallback.ts:143
↓ 2 callers
Function
bindCallbackInternals
( isNodeStyle: boolean, callbackFunc: any, resultSelector?: any, scheduler?: SchedulerLike )
packages/rxjs/src/internal/observable/bindCallbackInternals.ts:8
↓ 2 callers
Function
buffer
(closingNotifier: ObservableInput<any>)
packages/rxjs/src/internal/operators/buffer.ts:43
↓ 2 callers
Function
bufferCount
(bufferSize: number, startBufferEvery: number | null = null)
packages/rxjs/src/internal/operators/bufferCount.ts:56
↓ 2 callers
Function
bufferTime
(bufferTimeSpan: number, ...otherArgs: any[])
packages/rxjs/src/internal/operators/bufferTime.ts:73
↓ 2 callers
Function
bufferToggle
( openings: ObservableInput<O>, closingSelector: (value: O) => ObservableInput<any> )
packages/rxjs/src/internal/operators/bufferToggle.ts:49
↓ 2 callers
Function
bufferWhen
(closingSelector: () => ObservableInput<any>)
packages/rxjs/src/internal/operators/bufferWhen.ts:44
↓ 2 callers
Function
build
(apiList: FlattenedApiList, tree: TreeNodeRaw[], log: { warn: (message: string) => void })
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/build.ts:17
↓ 2 callers
Method
calculateTop
(scrollTop: number, topOffset: number)
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:46
↓ 2 callers
Function
cancelReset
()
packages/rxjs/src/internal/operators/share.ts:150
↓ 2 callers
Function
checkComplete
()
packages/rxjs/src/internal/operators/repeatWhen.ts:52
↓ 2 callers
Function
checkComplete
()
packages/rxjs/src/internal/operators/mergeInternals.ts:41
↓ 2 callers
Function
clearInterval
(handle)
packages/rxjs/src/internal/scheduler/intervalProvider.ts:26
↓ 2 callers
Function
closeWindow
(record: { window: Subject<T>; subs: Subscription })
packages/rxjs/src/internal/operators/windowTime.ts:116
↓ 2 callers
Function
combineLatestAll
(project?: (...values: Array<any>) => R)
packages/rxjs/src/internal/operators/combineLatestAll.ts:48
↓ 2 callers
Function
combineLatestInit
(observables: ObservableInput<any>[], valueTransform: (values: any[]) => any = identity)
packages/rxjs/src/internal/observable/combineLatest.ts:196
↓ 2 callers
Function
combineLatestWith
( ...otherSources: [...ObservableInputTuple<A>] )
packages/rxjs/src/internal/operators/combineLatestWith.ts:45
↓ 2 callers
Method
complete
()
packages/rxjs/src/internal/AsyncSubject.ts:31
↓ 2 callers
Function
concatMapTo
(innerObservable: O)
packages/rxjs/src/internal/operators/concatMapTo.ts:60
↓ 2 callers
Function
connect
( selector: (shared: Observable<T>) => O, config: ConnectConfig<T> = DEFAULT_CONFIG )
packages/rxjs/src/internal/operators/connect.ts:97
↓ 2 callers
Method
create
(worker: Worker, zone: NgZone)
apps/rxjs.dev/src/app/shared/web-worker.ts:14
↓ 2 callers
Function
createBindingInfo
(propertyName, bindingName)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/matchUpDirectiveDecorators.js:80
↓ 2 callers
Function
createFind
( predicate: (value: T, index: number, source: Observable<T>) => boolean, emit: 'value' | 'index', sourc
packages/rxjs/src/internal/operators/find.ts:54
↓ 2 callers
Function
createLinkNode
(doc, text)
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:147
↓ 2 callers
Function
createObject
(keys: string[], values: any[])
packages/rxjs/src/internal/util/createObject.ts:1
↓ 2 callers
Function
createOpenMatcher
(elementNameMatcher)
apps/rxjs.dev/tools/transforms/remark-package/services/renderMarkdown.js:202
↓ 2 callers
Function
createResponse
(direction: AjaxDirection, event: ProgressEvent)
packages/rxjs/src/internal/ajax/ajax.ts:435
↓ 2 callers
Function
debounce
(durationSelector: (value: T) => ObservableInput<any>)
packages/rxjs/src/internal/operators/debounce.ts:64
↓ 2 callers
Function
decisionTreeReducer
(tree: TreeNode[], apiList: FlattenedApiList, log: { warn: (message: string) => void })
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/decisionTreeReducer.ts:12
↓ 2 callers
Function
defaultIfEmpty
(defaultValue: R)
packages/rxjs/src/internal/operators/defaultIfEmpty.ts:39
↓ 2 callers
Function
dematerialize
()
packages/rxjs/src/internal/operators/dematerialize.ts:53
↓ 2 callers
Function
distinctUntilKeyChanged
( key: K, compare?: (x: T[K], y: T[K]) => boolean )
packages/rxjs/src/internal/operators/distinctUntilKeyChanged.ts:70
↓ 2 callers
Function
doPrepareTitleAndToc
(contents: string, docId = '')
apps/rxjs.dev/src/app/layout/doc-viewer/doc-viewer.component.spec.ts:127
↓ 2 callers
Method
doSearch
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:51
↓ 2 callers
Function
elementAt
(index: number, defaultValue?: D)
packages/rxjs/src/internal/operators/elementAt.ts:54
↓ 2 callers
Function
emit
(record: { buffer: T[]; subs: Subscription })
packages/rxjs/src/internal/operators/bufferTime.ts:92
↓ 2 callers
Function
endWith
(...values: A)
packages/rxjs/src/internal/operators/endWith.ts:52
↓ 2 callers
Function
every
( predicate: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any )
packages/rxjs/src/internal/operators/every.ts:42
↓ 2 callers
Function
execFinalizer
(finalizer: Unsubscribable | (() => void))
packages/rxjs/src/internal/Observable.ts:192
↓ 2 callers
Function
exhaustAll
()
packages/rxjs/src/internal/operators/exhaustAll.ts:49
↓ 2 callers
Function
expand
( project: (value: T, index: number) => O, concurrent = Infinity, scheduler?: SchedulerLike )
packages/rxjs/src/internal/operators/expand.ts:71
↓ 2 callers
Function
extractInitialSequence
(tree: TreeNode[])
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/extractInitialSequence.ts:10
↓ 2 callers
Method
fetchSections
* 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 callers
Function
find
(predicate: (value: T, index: number, source: Observable<T>) => boolean)
packages/rxjs/src/internal/operators/find.ts:50
↓ 2 callers
Function
findAndClearHandle
* 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 callers
Function
findIndex
(predicate: (value: T, index: number, source: Observable<T>) => boolean)
packages/rxjs/src/internal/operators/findIndex.ts:49
↓ 2 callers
Function
flattenApiList
(apiList: ApiListNode[])
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/flattenApiList.ts:14
↓ 2 callers
Method
focus
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:59
↓ 2 callers
Function
forkJoin
(...args: any[])
packages/rxjs/src/internal/observable/forkJoin.ts:144
↓ 2 callers
Method
formatDisplayedCode
()
apps/rxjs.dev/src/app/custom-elements/code/code.component.ts:133
↓ 2 callers
Function
foundValidDoc
* 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 callers
Function
fromArrayLike
(array: ArrayLike<T>)
packages/rxjs/src/internal/Observable.ts:1149
↓ 2 callers
Function
fromAsyncIterable
(asyncIterable: AsyncIterable<T>)
packages/rxjs/src/internal/Observable.ts:1183
↓ 2 callers
Function
fromFetch
( input: string | Request, initWithSelector: RequestInit & { selector?: (response: Response) => Observ
packages/rxjs/src/internal/observable/dom/fetch.ts:93
↓ 2 callers
Function
fromPromise
(promise: PromiseLike<T>)
packages/rxjs/src/internal/Observable.ts:1155
↓ 2 callers
Function
generateUniqueId
()
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/generateUniqueId.ts:10
↓ 2 callers
Method
getAllResponseHeaders
()
packages/rxjs/spec/observables/dom/ajax-spec.ts:1643
↓ 2 callers
Function
getAnchors
()
apps/rxjs.dev/src/app/custom-elements/live-example/live-example.component.spec.ts:28
↓ 2 callers
Function
getApiSections
()
apps/rxjs.dev/src/app/custom-elements/api/api-list.component.spec.ts:287
↓ 2 callers
Method
getContentHeight
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:164
↓ 2 callers
Method
getCurrentHash
* Return the hash fragment from the `PlatformLocation`, minus the leading `#`.
apps/rxjs.dev/src/app/shared/scroll.service.ts:201
↓ 2 callers
Method
getDecisionTree$
()
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/operator-decision-tree-data.service.ts:10
↓ 2 callers
Method
getDocument
(url: string)
apps/rxjs.dev/src/app/documents/document.service.ts:46
↓ 2 callers
Function
getFilteredDocsFromAlias
(words, index)
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:84
↓ 2 callers
Method
getJSON
* 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 callers
Function
getObservableInputType
(input: unknown)
packages/rxjs/src/internal/Observable.ts:1240
↓ 2 callers
Method
getTopOffset
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.ts:172
↓ 2 callers
Function
groupBy
( keySelector: (value: T) => K, elementOrOptions?: ((value: any) => any) | void | BasicGroupByOptions<K, T
packages/rxjs/src/internal/operators/groupBy.ts:138
↓ 2 callers
Method
handleAnchorClick
* 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 callers
Function
handleError
(err: any)
packages/rxjs/src/internal/operators/groupBy.ts:164
↓ 2 callers
Method
handleError
(error: ErrorEvent)
apps/rxjs.dev/src/app/shared/web-worker.ts:34
↓ 2 callers
Function
handler
(arg: any)
packages/rxjs/spec/observables/from-spec.ts:279
↓ 2 callers
Method
hideSearchResults
()
apps/rxjs.dev/src/app/app.component.ts:461
↓ 2 callers
Function
iif
(condition: () => boolean, trueResult: ObservableInput<T>, falseResult: ObservableInput<F>)
packages/rxjs/src/internal/observable/iif.ts:83
↓ 2 callers
Function
interopSubscribe
(subscribe: (...args: any[]) => Subscription)
packages/rxjs/spec/helpers/interop-helper.ts:55
↓ 2 callers
Function
isArrayLike
(x: any)
packages/rxjs/src/internal/Observable.ts:1320
↓ 2 callers
Function
isEmpty
()
packages/rxjs/src/internal/operators/isEmpty.ts:65
↓ 2 callers
Function
isEventTarget
* 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 callers
Function
isInitialDecision
(previousBranchIds: string[])
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/utils.ts:3
↓ 2 callers
Function
isInsideLink
(ancestors)
apps/rxjs.dev/tools/transforms/angular-base-package/post-processors/auto-link-code.js:80
↓ 2 callers
Function
isJQueryStyleEventEmitter
* 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 callers
Method
isLocationWithHash
* test if the current location has a hash
apps/rxjs.dev/src/app/shared/scroll.service.ts:94
↓ 2 callers
Function
isNodeStyleEventEmitter
* 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 callers
Function
isPromise
(value: any)
packages/rxjs/src/internal/Observable.ts:1306
↓ 2 callers
Function
isStable
(stability: string)
apps/rxjs.dev/tools/transforms/rxjs-decision-tree-generator/src/lib/helpers.ts:14
↓ 2 callers
Function
joinAllInternals
(joinFn: (sources: ObservableInput<T>[]) => Observable<T>, project?: (...args: any[]) => R)
packages/rxjs/src/internal/operators/joinAllInternals.ts:19
↓ 2 callers
Function
last
( predicate?: ((value: T, index: number, source: Observable<T>) => boolean) | null, defaultValue?: D )
packages/rxjs/src/internal/operators/last.ts:75
↓ 2 callers
Function
lastValueFrom
(source: Observable<T>, config?: LastValueFromConfig<D>)
packages/rxjs/src/internal/lastValueFrom.ts:54
↓ 2 callers
Method
loadContainedCustomElements
* 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 callers
Method
locationChanged
(url: string)
apps/rxjs.dev/src/app/shared/ga.service.ts:20
← previous
next →
201–300 of 1,267, ranked by callers