MCPcopy Create free account

hub / github.com/ReactiveX/rxjs / functions

Functions2,527 in github.com/ReactiveX/rxjs

⨍ Functions 2,527◇ Types & classes 754
↓ 1 callersFunctionwithRequiredImports
( sourceFile: ts.SourceFile, imports: ReadonlyMap<string, ReadonlySet<string>>, factory: ts.NodeFactory
packages/migrate/src/semantics.ts:822
↓ 1 callersFunctionwithSafariDriver
(run, { port = 4444 } = {})
packages/rxjs/test/release/safari-driver.mjs:21
↓ 1 callersFunctionwriteAuditFiles
({ runRoot, audit, bundleManifest, config, expectedUrlCount, mode, reportPath, humanLogPath,
packages/observable-polyfill/test/wpt/lib/runner.mjs:196
↓ 1 callersFunctionwriteConsumerFixtures
(root)
scripts/qualify-prerelease.mjs:94
↓ 1 callersFunctionwriteJson
(stream: Pick<NodeJS.WriteStream, 'write'>, value: unknown)
packages/migrate/src/skill-cli.ts:100
↓ 1 callersFunctionwriteJson
(stream: Pick<NodeJS.WriteStream, 'write'>, value: MigrationCliReport | MigrationCliErrorReport)
packages/migrate/src/cli.ts:186
↓ 1 callersFunctionwriteSource
(localPath: string)
packages/migrate/src/node.spec.ts:140
↓ 1 callersFunctiony
(a)
apps/rxjs.dev/src/assets/js/prettify.js:25
Method#flushTimers
(until: number)
packages/rxjs/src/testing/index.ts:193
Method$lastInfo
()
apps/rxjs.dev/src/app/shared/toc.service.spec.ts:356
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/computeStability.js:6
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/computeApiBreadCrumbs.js:5
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/splitDescription.js:11
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/computeSearchTitle.js:5
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/migrateLegacyJSDocTags.js:5
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/processClassLikeMembers.js:9
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/checkOperator.js:5
Function$process
()
apps/rxjs.dev/tools/transforms/angular-base-package/processors/copyContentAssets.js:6
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-base-package/processors/generateKeywords.js:25
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-base-package/processors/renderLinkInfo.js:11
Function$process
(docs)
apps/rxjs.dev/tools/transforms/angular-base-package/processors/createSitemap.js:15
FunctionAssertRecord
* @class * Record of an assert that ran. * * @param {Test} test - The test which ran the assert. * @param {string} assert_name - T
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:3644
FunctionAssertionError
* @class * Exception type that represents a failing assert. * * @param {string} message - Error message.
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4789
FunctionDedicatedWorkerTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:338
FunctionEventWatcher
* Allow DOM events to be handled using Promises. * * This can make it a lot easier to test a very specific series of events, * includin
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:956
FunctionIdlCallback
(obj)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:3272
FunctionIdlDictionary
(obj)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:1180
FunctionIdlEnum
(obj)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:3253
FunctionIdlInterface
(obj, is_callback, is_mixin)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:1210
FunctionIdlInterfaceMember
(obj)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:3153
FunctionIdlNamespace
(obj)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:3308
FunctionIdlObject
()
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:1156
FunctionIdlTypedef
(obj)
packages/observable-polyfill/test/wpt/upstream/resources/idlharness.js:3290
FunctionOptionalFeatureUnsupportedError
(message)
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4839
MethodPatchedDate
(...args: any[])
packages/rxjs/src/testing/index.ts:170
FunctionRemoteContext
(remote, message_target, message_filter)
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:3441
FunctionRemoteTest
* A RemoteTest object mirrors a Test object on a remote worker. The * associated RemoteWorker updates the RemoteTest object in response to *
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:3359
FunctionServiceWorkerTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:387
FunctionShadowRealmTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:439
FunctionSharedWorkerTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:361
FunctionShellTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:485
FunctionTest
* @class * * A single subtest. A Test is not constructed directly but via the * :js:func:`test`, :js:func:`async_test` or :js:func:`pro
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:2721
FunctionTests
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:3665
FunctionTestsStatus
* @class * Status of the overall harness
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:3583
FunctionWindowTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:51
FunctionWorkerTestEnvironment
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:253
Function[Symbol.asyncIterator]
()
packages/observable-polyfill/test/wpt/upstream/dom/observable/tentative/observable-from.any.js:627
Method[Symbol.dispose]
()
packages/test/src/virtual-time.ts:831
Function[Symbol.iterator]
()
packages/observable-polyfill/test/wpt/upstream/dom/observable/tentative/observable-from.any.js:48
Function[Symbol.iterator]
()
packages/rxjs/src/merge-scan.spec.ts:182
Function[Symbol.iterator]
()
packages/rxjs/src/switch-scan.spec.ts:146
Function[Symbol.iterator]
()
packages/rxjs/src/distinct.spec.ts:75
Function[Symbol.iterator]
()
packages/rxjs/src/window-when.spec.ts:393
Function[Symbol.iterator]
()
packages/rxjs/src/connect.spec.ts:410
Function[Symbol.iterator]
()
packages/rxjs/src/fork-join.spec.ts:123
Function[Symbol.iterator]
()
packages/rxjs/src/window-toggle.spec.ts:482
Function[Symbol.iterator]
()
packages/rxjs/src/zip.spec.ts:41
Function[Symbol.iterator]
()
packages/rxjs/src/zip-with.spec.ts:61
Method[Symbol.toPrimitive]
()
packages/test/src/virtual-time.ts:827
Method[addObserver]
(observer: SafeObserver<T>)
packages/observable-polyfill/src/index.ts:136
Method[bufferToggle]
( openings: ObservableValue<Opening>, closingSelector: (opening: Opening) => ObservableValue<unkno
packages/rxjs/src/buffer-toggle.ts:8
Method[closeSubscriber]
(reason?: unknown)
packages/observable-polyfill/src/index.ts:147
Method[connect]
( selector: (shared: Observable<T>) => Selected, config?: ConnectConfig<T> )
packages/rxjs/src/connect.ts:14
Method[delayWhen]
(durationSelector: (value: T, index: number) => ObservableValue<any>, subscriptionDelay?: Observable<any>)
packages/rxjs/src/delay-when.ts:8
Method[dematerialize]
()
packages/rxjs/src/dematerialize.ts:9
Method[elementAt]
(index: number)
packages/rxjs/src/element-at.ts:10
Method[errorSubscriber]
(error: any, hasSourceLocation: boolean)
packages/observable-polyfill/src/index.ts:229
Method[expand]
(project: (value: T, index: number) => ObservableValue<R>, options?: ExpandOptions)
packages/rxjs/src/expand.ts:12
Method[isEmpty]
()
packages/rxjs/src/is-empty.ts:8
Method[materialize]
()
packages/rxjs/src/materialize.ts:9
Method[mergeScan]
( accumulator: (accumulator: R, value: T, index: number) => ObservableValue<R>, seed: R, con
packages/rxjs/src/merge-scan.ts:8
Method[min]
(comparer?: (previous: T, current: T) => number)
packages/rxjs/src/min.ts:7
Method[multicast]
(subject: SubjectLike<T>)
packages/rxjs/src/multicast.ts:9
Function[observableKey]
()
packages/rxjs/test/ported/cold/observables/merge.spec.ts:257
Function[observableKey]
()
packages/rxjs/test/ported/platform/observables/merge.spec.ts:256
Method[observeOn]
(delay?: number)
packages/rxjs/src/observe-on.ts:8
Method[publishBehavior]
(initialValue: T)
packages/rxjs/src/publish-behavior.ts:9
Method[publishLast]
()
packages/rxjs/src/publish-last.ts:9
Method[publishReplay]
( bufferSize: number | undefined, windowTime: number | undefined, selector: (shared: Observa
packages/rxjs/src/publish-replay.ts:16
Method[publish]
()
packages/rxjs/src/publish.ts:10
Method[refCount]
(this: ConnectableObservable<T>)
packages/rxjs/src/ref-count.ts:9
Method[repeatWhen]
(notifier: (completions: Observable<void>) => ObservableValue<unknown>)
packages/rxjs/src/repeat-when.ts:9
Method[retryWhen]
(notifier: (errors: Observable<any>) => ObservableValue<any>)
packages/rxjs/src/retry-when.ts:9
Method[retry]
(config?: { count?: number; delay?: number | ((error: any, retryCount: number) => ObservableValue<
packages/rxjs/src/retry.ts:9
Method[sample]
(notifier: ObservableValue<unknown>)
packages/rxjs/src/sample.ts:8
Method[scan]
(accumulator: (accumulator: A | T, value: T, index: number) => A)
packages/rxjs/src/scan.ts:8
Method[sequenceEqual]
(other: Observable<T>, comparator?: (left: T, right: T) => boolean)
packages/rxjs/src/sequence-equal.ts:9
Method[shareReplay]
(config: ShareReplayConfig)
packages/rxjs/src/share-replay.ts:15
Method[share]
(config?: ShareConfig<T>)
packages/rxjs/src/share.ts:20
Method[startWith]
(...values: A)
packages/rxjs/src/start-with.ts:8
Method[subscribeOn]
(delay?: number)
packages/rxjs/src/subscribe-on.ts:8
Method[switchScan]
( accumulator: (accumulator: R, value: T, index: number) => Input, seed: R )
packages/rxjs/src/switch-scan.ts:9
Method[takeUntil]
(notifier: ObservableValue<any>)
packages/rxjs/src/take-until.ts:8
Method[throwIfEmpty]
(errorFactory?: () => unknown)
packages/rxjs/src/throw-if-empty.ts:9
Method[windowCount]
(windowSize: number, startWindowEvery?: number)
packages/rxjs/src/window-count.ts:9
Method[windowToggle]
( openings: ObservableValue<Opening>, closingSelector: (opening: Opening) => ObservableValue<unkno
packages/rxjs/src/window-toggle.ts:9
Method[windowWhen]
(closingSelector: () => ObservableValue<unknown>)
packages/rxjs/src/window-when.ts:9
Method[window]
(boundaries: ObservableValue<any>)
packages/rxjs/src/window.ts:9
Function_subscribe
* Performs setup for one direct subscription to this Subject instance. * * `ColdObservable.subscribe()` calls this hook once for each direct
packages/rxjs/src/per-subscription-subject-base.ts:83
Method_subscribe
(subscriber: Subscriber<T>)
packages/rxjs/src/per-subscription-subject-base.spec.ts:12
← previousnext →1,601–1,700 of 2,527, ranked by callers