MCPcopy Create free account

hub / github.com/ReactiveX/rxjs / functions

Functions1,267 in github.com/ReactiveX/rxjs

↓ 265 callersMethodpipe
* Used to stitch together functional operators into a chain. * * ## Example * * ```ts * import { interval, filter, map, scan } from 'rx
packages/rxjs/src/internal/Observable.ts:883
↓ 261 callersMethodsubscribe
(observer: Partial<Observer<T>>)
packages/rxjs/src/internal/types.ts:91
↓ 236 callersFunctionof
(...values: T[])
packages/rxjs/src/internal/observable/of.ts:72
↓ 172 callersMethodtoBe
(marbles: string, values?: any, errorValue?: any)
packages/rxjs/src/internal/testing/TestScheduler.ts:166
↓ 132 callersMethodrun
()
packages/rxjs/src/internal/testing/TestScheduler.ts:525
↓ 129 callersFunctionexpectObservable
(observable: Observable<any>, unsubscriptionMarbles: string | null = null)
packages/rxjs/spec/helpers/marble-testing.ts:27
↓ 112 callersFunctioncold
(marbles: string, values?: any, error?: any)
packages/rxjs/spec/helpers/marble-testing.ts:20
↓ 108 callersFunctionhot
(marbles: string, values?: { [index: string]: V } | void, error?: any)
packages/rxjs/spec/helpers/marble-testing.ts:11
↓ 107 callersFunctionexpectSubscriptions
(actualSubscriptionLogs: SubscriptionLog[])
packages/rxjs/spec/helpers/marble-testing.ts:34
↓ 102 callersFunctionmergeMap
( project: (value: T, index: number) => O, concurrent: number = Infinity )
packages/rxjs/src/internal/operators/mergeMap.ts:58
↓ 84 callersMethodunsubscribe
()
packages/rxjs/src/internal/types.ts:78
↓ 81 callersMethodnext
(value: number)
packages/rxjs/spec/subjects/AsyncSubject-spec.ts:8
↓ 80 callersFunctiontake
(count: number)
packages/rxjs/src/internal/operators/take.ts:47
↓ 76 callersMethodnext
(value: In)
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:323
↓ 74 callersMethodget
* 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:66
↓ 73 callersFunctionoperate
({ destination, ...subscriberOverrides }: OperateConfig<In, Out>)
packages/rxjs/src/internal/Observable.ts:536
↓ 71 callersMethodresolve
()
apps/rxjs.dev/src/app/custom-elements/elements-loader.spec.ts:15
↓ 69 callersMethodforEach
* Used as a NON-CANCELLABLE means of subscribing to an observable, for use with * APIs that expect promises, like `async/await`. You cannot unsubsc
packages/rxjs/src/internal/Observable.ts:757
↓ 68 callersFunctionfrom
(input: ObservableInput<T>)
packages/rxjs/src/internal/Observable.ts:1107
↓ 62 callersMethodcomplete
()
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:350
↓ 57 callersFunctionmap
(project: (value: T, index: number) => R)
packages/rxjs/src/internal/operators/map.ts:39
↓ 35 callersMethodnext
(value: T)
packages/rxjs/src/internal/Subject.ts:54
↓ 34 callersMethodadd
* Adds a finalizer to this subscription, so that finalization will be unsubscribed/called * when this subscription is unsubscribed. If this subscri
packages/rxjs/src/internal/Observable.ts:134
↓ 32 callersMethodcomplete
()
packages/rxjs/spec/subjects/AsyncSubject-spec.ts:16
↓ 32 callersMethodlog
(value: any, ...rest: any[])
apps/rxjs.dev/src/app/shared/logger.service.ts:10
↓ 32 callersFunctiontap
(observerOrNext?: Partial<TapObserver<T>> | ((value: T) => void) | null)
packages/rxjs/src/internal/operators/tap.ts:156
↓ 32 callersFunctiontime
(marbles: string)
packages/rxjs/spec/helpers/marble-testing.ts:41
↓ 29 callersFunctionsetTimeout
(handler: () => void, timeout?: number, ...args)
packages/rxjs/src/internal/scheduler/timeoutProvider.ts:19
↓ 28 callersMethoderror
(err: any)
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:335
↓ 28 callersMethodtest
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseGlob.ts:45
↓ 26 callersMethod$process
(docs: DocCollection)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/markAliases.ts:18
↓ 25 callersMethodthen
( onFulfilled?: ((value: T) => TResult1 | PromiseLike<TResult1>) | undefined | null, onRejecte
packages/rxjs/spec/observables/from-promise-spec.ts:71
↓ 25 callersFunctiontimer
( dueTime: number | Date = 0, intervalOrScheduler?: number | SchedulerLike, scheduler: SchedulerLike = a
packages/rxjs/src/internal/observable/timer.ts:134
↓ 24 callersFunctiondelay
(due: number | Date, scheduler: SchedulerLike = asyncScheduler)
packages/rxjs/src/internal/operators/delay.ts:62
↓ 24 callersMethodflush
()
packages/rxjs/src/internal/testing/TestScheduler.ts:209
↓ 23 callersFunctionisFunction
(value: any)
packages/rxjs/src/internal/Observable.ts:1273
↓ 22 callersMethodnow
* Returns a timestamp as a number. * * This is used by types like `ReplaySubject` or operators like `timestamp` to calculate * the amount of
packages/rxjs/src/internal/types.ts:236
↓ 22 callersMethodreject
(err: any)
apps/rxjs.dev/src/app/custom-elements/elements-loader.spec.ts:16
↓ 21 callersFunctiondefer
(observableFactory: () => R)
packages/rxjs/src/internal/observable/defer.ts:50
↓ 21 callersMethoderror
(err: any)
packages/rxjs/spec/subjects/AsyncSubject-spec.ts:12
↓ 21 callersMethodreplace
(url: string)
apps/rxjs.dev/src/app/shared/location.service.ts:56
↓ 19 callersMethodreplace
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseRedirect.ts:8
↓ 18 callersFunctionthrowError
(errorFactory: () => any)
packages/rxjs/src/internal/observable/throwError.ts:95
↓ 17 callersMethodasObservable
* Creates a new Observable with this Subject as the source. You can do this * to create custom Observer-side logic of the Subject and conceal it fr
packages/rxjs/src/internal/Subject.ts:137
↓ 17 callersFunctionscheduled
(input: ObservableInput<T>, scheduler: SchedulerLike)
packages/rxjs/src/internal/scheduled/scheduled.ts:22
↓ 16 callersMethodcall
(subscriber: Subscriber<R>, source: any)
packages/rxjs/src/internal/Operator.ts:8
↓ 16 callersFunctionconcat
(...args: any[])
packages/rxjs/src/internal/observable/concat.ts:114
↓ 16 callersMethoderror
(error: Error)
apps/rxjs.dev/src/app/shared/logger.service.ts:16
↓ 16 callersMethodmatch
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseGlob.ts:49
↓ 15 callersFunctionexecuteSchedule
( parentSubscription: Subscription, scheduler: SchedulerLike, work: () => void, delay = 0, repeat =
packages/rxjs/src/internal/util/executeSchedule.ts:4
↓ 14 callersFunctioninterval
(period = 0, scheduler: SchedulerLike = asyncScheduler)
packages/rxjs/src/internal/observable/interval.ts:50
↓ 14 callersFunctionmerge
(...args: (ObservableInput<unknown> | number | SchedulerLike)[])
packages/rxjs/src/internal/observable/merge.ts:87
↓ 13 callersMethodclose
(code: any, reason: any)
packages/rxjs/spec/observables/dom/webSocket-spec.ts:808
↓ 13 callersFunctiontakeUntil
(notifier: ObservableInput<any>)
packages/rxjs/src/internal/operators/takeUntil.ts:43
↓ 12 callersFunctionasInteropObservable
(observable: Observable<T>)
packages/rxjs/spec/helpers/interop-helper.ts:10
↓ 12 callersMethoderror
(err: any)
packages/rxjs/src/internal/Subject.ts:64
↓ 12 callersFunctionfinalize
(callback: () => void)
packages/rxjs/src/internal/operators/finalize.ts:65
↓ 12 callersMethodschedule
(work: (this: SchedulerAction<T>, state: T) => void, delay: number, state: T)
packages/rxjs/src/internal/types.ts:217
↓ 11 callersFunctionfilter
(predicate: (value: T, index: number) => boolean, thisArg?: any)
packages/rxjs/src/internal/operators/filter.ts:60
↓ 11 callersFunctionswitchMap
( project: (value: T, index: number) => O )
packages/rxjs/src/internal/operators/switchMap.ts:66
↓ 11 callersFunctiontakeWhile
(predicate: (value: T, index: number) => boolean, inclusive = false)
packages/rxjs/src/internal/operators/takeWhile.ts:54
↓ 10 callersMethoddelete
* Performs an HTTP DELETE using the * [XMLHttpRequest](https://developer.mozilla.org/en-US/docs/Web/API/XMLHttpRequest) in * global scope by def
packages/rxjs/src/internal/ajax/ajax.ts:124
↓ 10 callersMethodnext
(value: string)
packages/rxjs/spec/Subscriber-spec.ts:180
↓ 10 callersMethodquery
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:63
↓ 10 callersMethodschedule
(callback: FrameRequestCallback)
packages/rxjs/src/internal/scheduler/animationFrameProvider.ts:4
↓ 10 callersMethodwarn
(value: any, ...rest: any[])
apps/rxjs.dev/src/app/shared/logger.service.ts:20
↓ 9 callersMethodaddEventListener
( type: string, listener: ((evt: E) => void) | EventListenerObject<E> | null, options?: boolean |
packages/rxjs/src/internal/observable/fromEvent.ts:40
↓ 9 callersFunctionconcatMap
( project: (value: T, index: number) => O )
packages/rxjs/src/internal/operators/concatMap.ts:60
↓ 9 callersFunctionrange
(start: number, count?: number, scheduler?: SchedulerLike)
packages/rxjs/src/internal/observable/range.ts:56
↓ 9 callersMethodreset
()
packages/rxjs/spec/observables/dom/fetch-spec.ts:86
↓ 8 callersFunctionclearTimeout
(handle)
packages/rxjs/src/internal/scheduler/timeoutProvider.ts:26
↓ 8 callersFunctioncombineLatest
( sources: Record<string, O> | O[], resultSelector?: (...value: any[]) => R )
packages/rxjs/src/internal/observable/combineLatest.ts:165
↓ 8 callersMethodconnect
* (Idempotent) Calling this method will connect the underlying source observable to all subscribed consumers * through an underlying {@link Subject
packages/rxjs/src/internal/types.ts:336
↓ 8 callersMethoderror
* The {@link Observer} callback to receive notifications of type `error` from * the Observable, with an attached `Error`. Notifies the Observer tha
packages/rxjs/src/internal/Observable.ts:331
↓ 8 callersFunctionerrorNotification
(error: any)
packages/rxjs/src/internal/Observable.ts:1346
↓ 8 callersFunctionmapTo
(value: R)
packages/rxjs/src/internal/operators/mapTo.ts:46
↓ 8 callersFunctionnextNotification
(value: T)
packages/rxjs/src/internal/Observable.ts:1355
↓ 7 callersFunctioncatchError
( selector: (err: any, caught: Observable<T>) => O )
packages/rxjs/src/internal/operators/catchError.ts:101
↓ 7 callersFunctionconcatWith
( ...otherSources: [...ObservableInputTuple<A>] )
packages/rxjs/src/internal/operators/concatWith.ts:45
↓ 7 callersFunctionfirst
( predicate?: ((value: T, index: number, source: Observable<T>) => boolean) | null, defaultValue?: D )
packages/rxjs/src/internal/operators/first.ts:79
↓ 7 callersFunctiongetAttrValue
(attrs: AttrMap, attr: string | string[])
apps/rxjs.dev/src/app/shared/attribute-utils.ts:28
↓ 7 callersFunctionmergeAll
(concurrent: number = Infinity)
packages/rxjs/src/internal/operators/mergeAll.ts:64
↓ 7 callersFunctionmergeMapTo
( innerObservable: O, concurrent?: number )
packages/rxjs/src/internal/operators/mergeMapTo.ts:45
↓ 7 callersFunctionpredicate
(x: T, y: T)
packages/rxjs/spec/operators/min-spec.ts:162
↓ 7 callersFunctionshare
(options: ShareConfig<T> = {})
packages/rxjs/src/internal/operators/share.ts:139
↓ 7 callersFunctionskip
(count: number)
packages/rxjs/src/internal/operators/skip.ts:37
↓ 7 callersFunctionstartWith
(...values: D[])
packages/rxjs/src/internal/operators/startWith.ts:47
↓ 7 callersFunctiontoArray
()
packages/rxjs/src/internal/operators/toArray.ts:37
↓ 6 callersFunctionarrRemove
(arr: T[] | undefined | null, item: T)
packages/rxjs/src/internal/util/arrRemove.ts:6
↓ 6 callersMethodcomplete
* The {@link Observer} callback to receive a valueless notification of type * `complete` from the Observable. Notifies the Observer that the Observ
packages/rxjs/src/internal/Observable.ts:345
↓ 6 callersMethodcomplete
()
packages/rxjs/src/internal/Subject.ts:77
↓ 6 callersFunctionfactory
()
packages/rxjs/spec-dtslint/operators/share-spec.ts:13
↓ 6 callersFunctionfn
()
packages/rxjs/spec-dtslint/operators/mergeMapTo-spec.ts:38
↓ 6 callersMethodgo
(url: string|null|undefined)
apps/rxjs.dev/src/app/shared/location.service.ts:39
↓ 6 callersMethodnext
* The {@link Observer} callback to receive notifications of type `next` from * the Observable, with a value. The Observable may call this method 0
packages/rxjs/src/internal/Observable.ts:317
↓ 6 callersMethodon
(eventName: string, handler: (this: TContext, t: T, ...args: any[]) => any)
packages/rxjs/src/internal/observable/fromEvent.ts:31
↓ 6 callersMethodopen
()
packages/rxjs/spec/observables/dom/webSocket-spec.ts:803
↓ 6 callersMethodparseMarbles
( marbles: string, values?: any, errorValue?: any, materializeInnerObservables: boolean = fals
packages/rxjs/src/internal/testing/TestScheduler.ts:323
↓ 6 callersFunctionreduce
(accumulator: (acc: V | A, value: V, index: number) => A, seed?: any)
packages/rxjs/src/internal/operators/reduce.ts:59
↓ 6 callersFunctionretry
(configOrCount: number | RetryConfig = Infinity)
packages/rxjs/src/internal/operators/retry.ts:82
next →1–100 of 1,267, ranked by callers