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
↓ 265 callers
Method
pipe
* 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 callers
Method
subscribe
(observer: Partial<Observer<T>>)
packages/rxjs/src/internal/types.ts:91
↓ 236 callers
Function
of
(...values: T[])
packages/rxjs/src/internal/observable/of.ts:72
↓ 172 callers
Method
toBe
(marbles: string, values?: any, errorValue?: any)
packages/rxjs/src/internal/testing/TestScheduler.ts:166
↓ 132 callers
Method
run
()
packages/rxjs/src/internal/testing/TestScheduler.ts:525
↓ 129 callers
Function
expectObservable
(observable: Observable<any>, unsubscriptionMarbles: string | null = null)
packages/rxjs/spec/helpers/marble-testing.ts:27
↓ 112 callers
Function
cold
(marbles: string, values?: any, error?: any)
packages/rxjs/spec/helpers/marble-testing.ts:20
↓ 108 callers
Function
hot
(marbles: string, values?: { [index: string]: V } | void, error?: any)
packages/rxjs/spec/helpers/marble-testing.ts:11
↓ 107 callers
Function
expectSubscriptions
(actualSubscriptionLogs: SubscriptionLog[])
packages/rxjs/spec/helpers/marble-testing.ts:34
↓ 102 callers
Function
mergeMap
( project: (value: T, index: number) => O, concurrent: number = Infinity )
packages/rxjs/src/internal/operators/mergeMap.ts:58
↓ 84 callers
Method
unsubscribe
()
packages/rxjs/src/internal/types.ts:78
↓ 81 callers
Method
next
(value: number)
packages/rxjs/spec/subjects/AsyncSubject-spec.ts:8
↓ 80 callers
Function
take
(count: number)
packages/rxjs/src/internal/operators/take.ts:47
↓ 76 callers
Method
next
(value: In)
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:323
↓ 74 callers
Method
get
* 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 callers
Function
operate
({ destination, ...subscriberOverrides }: OperateConfig<In, Out>)
packages/rxjs/src/internal/Observable.ts:536
↓ 71 callers
Method
resolve
()
apps/rxjs.dev/src/app/custom-elements/elements-loader.spec.ts:15
↓ 69 callers
Method
forEach
* 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 callers
Function
from
(input: ObservableInput<T>)
packages/rxjs/src/internal/Observable.ts:1107
↓ 62 callers
Method
complete
()
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:350
↓ 57 callers
Function
map
(project: (value: T, index: number) => R)
packages/rxjs/src/internal/operators/map.ts:39
↓ 35 callers
Method
next
(value: T)
packages/rxjs/src/internal/Subject.ts:54
↓ 34 callers
Method
add
* 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 callers
Method
complete
()
packages/rxjs/spec/subjects/AsyncSubject-spec.ts:16
↓ 32 callers
Method
log
(value: any, ...rest: any[])
apps/rxjs.dev/src/app/shared/logger.service.ts:10
↓ 32 callers
Function
tap
(observerOrNext?: Partial<TapObserver<T>> | ((value: T) => void) | null)
packages/rxjs/src/internal/operators/tap.ts:156
↓ 32 callers
Function
time
(marbles: string)
packages/rxjs/spec/helpers/marble-testing.ts:41
↓ 29 callers
Function
setTimeout
(handler: () => void, timeout?: number, ...args)
packages/rxjs/src/internal/scheduler/timeoutProvider.ts:19
↓ 28 callers
Method
error
(err: any)
packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts:335
↓ 28 callers
Method
test
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseGlob.ts:45
↓ 26 callers
Method
$process
(docs: DocCollection)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/markAliases.ts:18
↓ 25 callers
Method
then
( onFulfilled?: ((value: T) => TResult1 | PromiseLike<TResult1>) | undefined | null, onRejecte
packages/rxjs/spec/observables/from-promise-spec.ts:71
↓ 25 callers
Function
timer
( dueTime: number | Date = 0, intervalOrScheduler?: number | SchedulerLike, scheduler: SchedulerLike = a
packages/rxjs/src/internal/observable/timer.ts:134
↓ 24 callers
Function
delay
(due: number | Date, scheduler: SchedulerLike = asyncScheduler)
packages/rxjs/src/internal/operators/delay.ts:62
↓ 24 callers
Method
flush
()
packages/rxjs/src/internal/testing/TestScheduler.ts:209
↓ 23 callers
Function
isFunction
(value: any)
packages/rxjs/src/internal/Observable.ts:1273
↓ 22 callers
Method
now
* 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 callers
Method
reject
(err: any)
apps/rxjs.dev/src/app/custom-elements/elements-loader.spec.ts:16
↓ 21 callers
Function
defer
(observableFactory: () => R)
packages/rxjs/src/internal/observable/defer.ts:50
↓ 21 callers
Method
error
(err: any)
packages/rxjs/spec/subjects/AsyncSubject-spec.ts:12
↓ 21 callers
Method
replace
(url: string)
apps/rxjs.dev/src/app/shared/location.service.ts:56
↓ 19 callers
Method
replace
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseRedirect.ts:8
↓ 18 callers
Function
throwError
(errorFactory: () => any)
packages/rxjs/src/internal/observable/throwError.ts:95
↓ 17 callers
Method
asObservable
* 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 callers
Function
scheduled
(input: ObservableInput<T>, scheduler: SchedulerLike)
packages/rxjs/src/internal/scheduled/scheduled.ts:22
↓ 16 callers
Method
call
(subscriber: Subscriber<R>, source: any)
packages/rxjs/src/internal/Operator.ts:8
↓ 16 callers
Function
concat
(...args: any[])
packages/rxjs/src/internal/observable/concat.ts:114
↓ 16 callers
Method
error
(error: Error)
apps/rxjs.dev/src/app/shared/logger.service.ts:16
↓ 16 callers
Method
match
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseGlob.ts:49
↓ 15 callers
Function
executeSchedule
( parentSubscription: Subscription, scheduler: SchedulerLike, work: () => void, delay = 0, repeat =
packages/rxjs/src/internal/util/executeSchedule.ts:4
↓ 14 callers
Function
interval
(period = 0, scheduler: SchedulerLike = asyncScheduler)
packages/rxjs/src/internal/observable/interval.ts:50
↓ 14 callers
Function
merge
(...args: (ObservableInput<unknown> | number | SchedulerLike)[])
packages/rxjs/src/internal/observable/merge.ts:87
↓ 13 callers
Method
close
(code: any, reason: any)
packages/rxjs/spec/observables/dom/webSocket-spec.ts:808
↓ 13 callers
Function
takeUntil
(notifier: ObservableInput<any>)
packages/rxjs/src/internal/operators/takeUntil.ts:43
↓ 12 callers
Function
asInteropObservable
(observable: Observable<T>)
packages/rxjs/spec/helpers/interop-helper.ts:10
↓ 12 callers
Method
error
(err: any)
packages/rxjs/src/internal/Subject.ts:64
↓ 12 callers
Function
finalize
(callback: () => void)
packages/rxjs/src/internal/operators/finalize.ts:65
↓ 12 callers
Method
schedule
(work: (this: SchedulerAction<T>, state: T) => void, delay: number, state: T)
packages/rxjs/src/internal/types.ts:217
↓ 11 callers
Function
filter
(predicate: (value: T, index: number) => boolean, thisArg?: any)
packages/rxjs/src/internal/operators/filter.ts:60
↓ 11 callers
Function
switchMap
( project: (value: T, index: number) => O )
packages/rxjs/src/internal/operators/switchMap.ts:66
↓ 11 callers
Function
takeWhile
(predicate: (value: T, index: number) => boolean, inclusive = false)
packages/rxjs/src/internal/operators/takeWhile.ts:54
↓ 10 callers
Method
delete
* 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 callers
Method
next
(value: string)
packages/rxjs/spec/Subscriber-spec.ts:180
↓ 10 callers
Method
query
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:63
↓ 10 callers
Method
schedule
(callback: FrameRequestCallback)
packages/rxjs/src/internal/scheduler/animationFrameProvider.ts:4
↓ 10 callers
Method
warn
(value: any, ...rest: any[])
apps/rxjs.dev/src/app/shared/logger.service.ts:20
↓ 9 callers
Method
addEventListener
( type: string, listener: ((evt: E) => void) | EventListenerObject<E> | null, options?: boolean |
packages/rxjs/src/internal/observable/fromEvent.ts:40
↓ 9 callers
Function
concatMap
( project: (value: T, index: number) => O )
packages/rxjs/src/internal/operators/concatMap.ts:60
↓ 9 callers
Function
range
(start: number, count?: number, scheduler?: SchedulerLike)
packages/rxjs/src/internal/observable/range.ts:56
↓ 9 callers
Method
reset
()
packages/rxjs/spec/observables/dom/fetch-spec.ts:86
↓ 8 callers
Function
clearTimeout
(handle)
packages/rxjs/src/internal/scheduler/timeoutProvider.ts:26
↓ 8 callers
Function
combineLatest
( sources: Record<string, O> | O[], resultSelector?: (...value: any[]) => R )
packages/rxjs/src/internal/observable/combineLatest.ts:165
↓ 8 callers
Method
connect
* (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 callers
Method
error
* 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 callers
Function
errorNotification
(error: any)
packages/rxjs/src/internal/Observable.ts:1346
↓ 8 callers
Function
mapTo
(value: R)
packages/rxjs/src/internal/operators/mapTo.ts:46
↓ 8 callers
Function
nextNotification
(value: T)
packages/rxjs/src/internal/Observable.ts:1355
↓ 7 callers
Function
catchError
( selector: (err: any, caught: Observable<T>) => O )
packages/rxjs/src/internal/operators/catchError.ts:101
↓ 7 callers
Function
concatWith
( ...otherSources: [...ObservableInputTuple<A>] )
packages/rxjs/src/internal/operators/concatWith.ts:45
↓ 7 callers
Function
first
( predicate?: ((value: T, index: number, source: Observable<T>) => boolean) | null, defaultValue?: D )
packages/rxjs/src/internal/operators/first.ts:79
↓ 7 callers
Function
getAttrValue
(attrs: AttrMap, attr: string | string[])
apps/rxjs.dev/src/app/shared/attribute-utils.ts:28
↓ 7 callers
Function
mergeAll
(concurrent: number = Infinity)
packages/rxjs/src/internal/operators/mergeAll.ts:64
↓ 7 callers
Function
mergeMapTo
( innerObservable: O, concurrent?: number )
packages/rxjs/src/internal/operators/mergeMapTo.ts:45
↓ 7 callers
Function
predicate
(x: T, y: T)
packages/rxjs/spec/operators/min-spec.ts:162
↓ 7 callers
Function
share
(options: ShareConfig<T> = {})
packages/rxjs/src/internal/operators/share.ts:139
↓ 7 callers
Function
skip
(count: number)
packages/rxjs/src/internal/operators/skip.ts:37
↓ 7 callers
Function
startWith
(...values: D[])
packages/rxjs/src/internal/operators/startWith.ts:47
↓ 7 callers
Function
toArray
()
packages/rxjs/src/internal/operators/toArray.ts:37
↓ 6 callers
Function
arrRemove
(arr: T[] | undefined | null, item: T)
packages/rxjs/src/internal/util/arrRemove.ts:6
↓ 6 callers
Method
complete
* 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 callers
Method
complete
()
packages/rxjs/src/internal/Subject.ts:77
↓ 6 callers
Function
factory
()
packages/rxjs/spec-dtslint/operators/share-spec.ts:13
↓ 6 callers
Function
fn
()
packages/rxjs/spec-dtslint/operators/mergeMapTo-spec.ts:38
↓ 6 callers
Method
go
(url: string|null|undefined)
apps/rxjs.dev/src/app/shared/location.service.ts:39
↓ 6 callers
Method
next
* 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 callers
Method
on
(eventName: string, handler: (this: TContext, t: T, ...args: any[]) => any)
packages/rxjs/src/internal/observable/fromEvent.ts:31
↓ 6 callers
Method
open
()
packages/rxjs/spec/observables/dom/webSocket-spec.ts:803
↓ 6 callers
Method
parseMarbles
( marbles: string, values?: any, errorValue?: any, materializeInnerObservables: boolean = fals
packages/rxjs/src/internal/testing/TestScheduler.ts:323
↓ 6 callers
Function
reduce
(accumulator: (acc: V | A, value: V, index: number) => A, seed?: any)
packages/rxjs/src/internal/operators/reduce.ts:59
↓ 6 callers
Function
retry
(configOrCount: number | RetryConfig = Infinity)
packages/rxjs/src/internal/operators/retry.ts:82
next →
1–100 of 1,267, ranked by callers