Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ReactiveX/rxjs
/ functions
Functions
2,527 in github.com/ReactiveX/rxjs
⨍
Functions
2,527
◇
Types & classes
754
↓ 470 callers
Method
toBe
Compares recorded notifications with a marble diagram.
packages/test/src/types.ts:132
↓ 355 callers
Method
from
(value: ObservableValue<T>)
packages/observable-polyfill/src/index.ts:1481
↓ 299 callers
Function
rxTest
(callback: RxTestCallback, config: RxTestConfig = {})
packages/test/src/rx-test.ts:23
↓ 294 callers
Method
complete
()
packages/test/src/types.ts:126
↓ 292 callers
Method
next
(value: T)
packages/test/src/types.ts:124
↓ 266 callers
Method
error
(error: unknown)
packages/test/src/types.ts:125
↓ 232 callers
Method
toEqual
Compares with another Observable recorded through the same window.
packages/test/src/types.ts:136
↓ 212 callers
Method
map
(project: (value: T) => R)
packages/migrate/test/mechanical/evidence.ts:30
↓ 210 callers
Method
subscribe
(observer?: Partial<PlatformObserver<T>> | ((value: T) => void) | null, options?: PlatformSubscribeOptions)
packages/test/src/platform-observable.ts:20
↓ 150 callers
Method
abort
()
packages/rxjs/test/ported/cold/observables/dom/ajax.spec.ts:48
↓ 144 callers
Method
addTeardown
(teardown: () => void)
packages/test/src/platform-observable.ts:13
↓ 93 callers
Method
filter
(predicate: (value: T, index: number) => boolean)
packages/rxjs/src/cold-observable.ts:124
↓ 86 callers
Function
subscribeToSource
( source: Observable<T>, subscriber: Subscriber<unknown>, overrides?: Partial<Observer<T>>, signal?: A
packages/rxjs/src/util/observable-helpers.ts:13
↓ 80 callers
Method
includes
()
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:2549
↓ 72 callers
Method
test
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseGlob.ts:45
↓ 70 callers
Method
parse
* @param {import("../tokeniser.js").Tokeniser} tokeniser
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:1895
↓ 69 callers
Method
resolve
()
apps/rxjs.dev/src/app/custom-elements/elements-loader.spec.ts:15
↓ 62 callers
Method
forEach
(handler: (value: T) => void, options?: SubscribeOptions)
packages/rxjs/src/cold-observable.ts:156
↓ 59 callers
Method
add
(teardown: () => void)
packages/migrate/test/agent/seed-oracles.spec.ts:12
↓ 58 callers
Method
write
@param {import("../writer.js").Writer} w
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:1300
↓ 56 callers
Method
replace
(url: string)
apps/rxjs.dev/src/app/shared/location.service.ts:56
↓ 42 callers
Method
abort
()
packages/observable-polyfill/src/index.ts:1216
↓ 42 callers
Method
next
(value: T)
packages/observable-polyfill/src/index.ts:206
↓ 39 callers
Method
apply
(compiler)
scripts/analyze-bundles.mjs:463
↓ 39 callers
Method
some
(predicate: (value: T, index: number) => boolean, options?: SubscribeOptions)
packages/rxjs/src/cold-observable.ts:172
↓ 37 callers
Method
pipe
(operator: (source: Rxjs7Observable<T>) => Rxjs7Observable<R>)
packages/migrate/test/mechanical/evidence.ts:13
↓ 34 callers
Function
assert
(expected_true, function_name, description, error, substitutions)
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4774
↓ 34 callers
Method
consume
* @param {...string} candidates
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:481
↓ 32 callers
Method
match
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseGlob.ts:49
↓ 27 callers
Function
schedule
()
packages/rxjs/test/ported/cold/observable.spec.ts:134
↓ 27 callers
Function
schedule
()
packages/rxjs/test/ported/platform/observable.spec.ts:133
↓ 26 callers
Method
$process
(docs: DocCollection)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/markAliases.ts:18
↓ 26 callers
Method
connect
()
packages/rxjs/src/connectable.ts:87
↓ 25 callers
Function
assert_array_equals
* Assert that ``actual`` and ``expected`` are both arrays, and that the array properties of * ``actual`` and ``expected`` are all the same value
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:1696
↓ 25 callers
Method
find
(predicate: (value: T, index: number) => boolean, options?: SubscribeOptions)
packages/rxjs/src/cold-observable.ts:168
↓ 25 callers
Method
log
(value: any, ...rest: any[])
apps/rxjs.dev/src/app/shared/logger.service.ts:10
↓ 24 callers
Method
token
* @param {import("./tokeniser.js").Token} t * @param {Function} wrapper * @param {...any} args * @returns
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:3782
↓ 23 callers
Method
subscribe
(observer?: Partial<Observer<T>> | ((value: T) => void) | null, options?: SubscribeOptions)
packages/observable-polyfill/src/index.ts:1458
↓ 22 callers
Function
map
(array, callable, thisObj)
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4873
↓ 21 callers
Function
test
* Create a synchronous test * * @param {TestFunction} func - Test function. This is executed * immediately. If it returns without error
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:624
↓ 21 callers
Method
toString
()
packages/rxjs/src/testing/index.ts:165
↓ 20 callers
Function
assert_equals
* Assert that ``actual`` is the same value as ``expected``. * * For objects this compares by object identity; for primitives * this dis
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:1586
↓ 20 callers
Method
consumeKind
* @param {...string} candidates
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:469
↓ 20 callers
Method
filter
(predicate: (value: T, index: number) => boolean)
packages/observable-polyfill/src/index.ts:671
↓ 20 callers
Method
unsubscribe
()
packages/rxjs/src/connectable.ts:11
↓ 19 callers
Function
promise_test
* Create a promise test. * * Promise tests are tests which are represented by a promise * object. If the promise is fulfilled the test
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:722
↓ 19 callers
Method
replace
(url: string)
apps/rxjs.dev/tools/firebase-test-utils/FirebaseRedirect.ts:8
↓ 18 callers
Method
#asPlatformObservable
()
packages/rxjs/src/cold-observable.ts:202
↓ 18 callers
Method
subscribe
(observer: Partial<Observer<T>> | ((value: T) => void) | null = {}, options: SubscribeOptions = {})
packages/observable-polyfill/src/index.ts:591
↓ 17 callers
Function
assert_true
* Assert that ``actual`` is strictly true * * @param {Any} actual - Value that is asserted to be true * @param {string} [description] -
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:1543
↓ 17 callers
Method
every
(predicate: (value: T, index: number) => boolean, options?: SubscribeOptions)
packages/rxjs/src/cold-observable.ts:176
↓ 16 callers
Method
catch
(handler: (error: any) => ObservableValue<R>)
packages/rxjs/src/cold-observable.ts:148
↓ 16 callers
Method
now
Returns elapsed virtual milliseconds since the test began.
packages/test/src/types.ts:171
↓ 15 callers
Method
reduce
( reducer: (accumulation: any, value: T, index: number) => any, ...args: [] | [initialValue: any, opti
packages/rxjs/src/cold-observable.ts:190
↓ 15 callers
Method
validate
(defs)
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:1236
↓ 14 callers
Method
asObservable
* Returns an Observable view that cannot be used to mutate this Subject. * * The view is constructed from Subject's selected platform Observable
packages/rxjs/src/subject.ts:85
↓ 14 callers
Function
gateOutcome
(id: AgentEvaluationGateId, findings: readonly string[])
packages/migrate/test/agent/evaluation.ts:727
↓ 14 callers
Method
reject
(err: any)
apps/rxjs.dev/src/app/custom-elements/elements-loader.spec.ts:16
↓ 13 callers
Method
abort
()
packages/rxjs/test/ported/platform/observables/dom/ajax.spec.ts:47
↓ 13 callers
Function
runProcess
(command, args, options = {})
packages/observable-polyfill/test/wpt/lib/process.mjs:3
↓ 13 callers
Method
useFakeTimers
()
packages/rxjs/src/testing/index.ts:209
↓ 13 callers
Method
useRealTimers
()
packages/rxjs/src/testing/index.ts:220
↓ 12 callers
Method
catch
(handler: (error: any) => ObservableValue<R>)
packages/observable-polyfill/src/index.ts:929
↓ 12 callers
Function
predicate
(x, y)
packages/rxjs/test/ported/cold/operators/min.spec.ts:95
↓ 11 callers
Function
assert_false
* Assert that ``actual`` is strictly false * * @param {Any} actual - Value that is asserted to be false * @param {string} [description]
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:1556
↓ 11 callers
Function
callback
()
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:77
↓ 11 callers
Method
toArray
()
packages/migrate/test/agent/seed-oracles.spec.ts:31
↓ 10 callers
Function
instanceCtor
(owner: any)
packages/observable-polyfill/src/index.ts:1257
↓ 10 callers
Method
query
()
apps/rxjs.dev/src/app/search/search-box/search-box.component.ts:63
↓ 10 callers
Method
some
(predicate: (value: T, index: number) => boolean, options?: SubscribeOptions)
packages/observable-polyfill/src/index.ts:1052
↓ 9 callers
Method
flush
Drains finite virtual work and evaluates current expectations.
packages/test/src/types.ts:187
↓ 9 callers
Method
forEach
(handler: (value: T) => void, options?: SubscribeOptions)
packages/observable-polyfill/src/index.ts:961
↓ 9 callers
Method
name_token
(t, arg)
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:3794
↓ 9 callers
Method
reject
(reason?: any)
packages/observable-polyfill/src/index.ts:1236
↓ 9 callers
Function
replaySubject
(config: ReplaySubjectConfig)
packages/rxjs/src/replay-subject.ts:106
↓ 9 callers
Function
zip
( sources: Sources, configOrProject?: | { fillAfterComplete?: Fill; } | ((...values:
packages/rxjs/src/zip.ts:27
↓ 8 callers
Method
#patch
(target: object, key: PropertyKey, value: unknown)
packages/test/src/virtual-time.ts:779
↓ 8 callers
Function
addFinding
(findings: QualificationFinding[], record: QualificationRecord, code: QualificationFindingCode, message: strin
packages/migrate/test/agent/qualification-record.ts:419
↓ 8 callers
Function
assert_unreached
* Asserts if called. Used to ensure that a specific codepath is * not taken e.g. that an error event isn't fired. * * @param {string} [
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:2622
↓ 8 callers
Method
close
(reason?: unknown)
packages/rxjs/src/connectable.ts:40
↓ 8 callers
Method
createComplete
()
packages/rxjs/src/notification.ts:88
↓ 8 callers
Method
createError
(error?: any)
packages/rxjs/src/notification.ts:84
↓ 8 callers
Method
createNext
(value: T)
packages/rxjs/src/notification.ts:80
↓ 8 callers
Function
getObservablePolyfillInfo
( constructor: ObservableCtor | undefined = globalThis.Observable )
packages/observable-polyfill/src/index.ts:1296
↓ 8 callers
Function
isFunction
(node)
packages/rxjs/test/ported/tools/generate-port-manifest.mjs:8984
↓ 8 callers
Method
now
()
packages/rxjs/src/timestamp.ts:7
↓ 8 callers
Function
pathExists
(filePath)
packages/observable-polyfill/test/wpt/lib/files.mjs:4
↓ 8 callers
Method
pipe
(first: LegacyOperator<T, A>)
packages/migrate/test/agent/seed-oracles.spec.ts:17
↓ 8 callers
Method
probe
* @param {string} value
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:460
↓ 8 callers
Method
reset
()
apps/rxjs.dev/src/app/shared/toc.service.ts:46
↓ 8 callers
Method
resolve
(value: T | PromiseLike<T>)
packages/observable-polyfill/src/index.ts:1227
↓ 8 callers
Function
test
(url)
apps/rxjs.dev/tools/transforms/angular.io-package/index.js:48
↓ 8 callers
Function
visit
(node)
packages/migrate/src/semantics.ts:120
↓ 8 callers
Method
warn
(value: any, ...rest: any[])
apps/rxjs.dev/src/app/shared/logger.service.ts:20
↓ 7 callers
Function
Output
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4285
↓ 7 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
↓ 7 callers
Function
error
(str)
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:69
↓ 7 callers
Method
flatMap
(mapper: (value: T, index: number) => ObservableValue<R>)
packages/rxjs/src/cold-observable.ts:136
↓ 7 callers
Function
getAttrValue
(attrs: AttrMap, attr: string | string[])
apps/rxjs.dev/src/app/shared/attribute-utils.ts:28
↓ 7 callers
Function
isObject
(value: unknown)
packages/observable-polyfill/src/index.ts:315
next →
1–100 of 2,527, ranked by callers