MCPcopy Create free account

hub / github.com/ReactiveX/rxjs / functions

Functions2,527 in github.com/ReactiveX/rxjs

↓ 2 callersMethodstartOver
()
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/operator-decision-tree.service.ts:97
↓ 2 callersFunctionstartSource
()
packages/rxjs/src/catch-error.ts:26
↓ 2 callersFunctionstartThrottle
(value: T)
packages/rxjs/src/throttle.ts:56
↓ 2 callersFunctionstatus_class
(status)
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4431
↓ 2 callersFunctionstripQuotes
(value)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/addMetadataAliases.js:47
↓ 2 callersFunctionstripQuotes
(value)
apps/rxjs.dev/tools/transforms/angular-api-package/processors/matchUpDirectiveDecorators.js:68
↓ 2 callersMethodstripSlashes
(url: string)
apps/rxjs.dev/src/app/shared/location.service.ts:60
↓ 2 callersFunctionstripTemplateQuotes
(title)
packages/rxjs/test/ported/tools/generate-port-manifest.mjs:7456
↓ 2 callersMethodsubscribe
(maybeObserver?: Partial<Observer<T>> | ((value: T) => void) | null, config?: SubscribeOptions)
packages/rxjs/src/cold-observable.ts:105
↓ 2 callersFunctionsummarizeGroup
(group, manifestById)
packages/rxjs/test/ported/tools/generate-failure-tracker.mjs:551
↓ 2 callersFunctionsummarizeIds
(caseIds)
packages/rxjs/test/ported/tools/mode-audit-baseline.mjs:130
↓ 2 callersMethodswitchMap
(mapper: (value: T, index: number) => ObservableValue<R>)
packages/observable-polyfill/src/index.ts:814
↓ 2 callersFunctionsynchronizeSkillInstallation
( options: SkillInstallOptions & { readonly operation: SkillInstallAction } )
packages/migrate/src/skill-install.ts:162
↓ 2 callersMethodtake
(amount: number)
packages/observable-polyfill/src/index.ts:699
↓ 2 callersFunctiontakeBuffer
()
packages/rxjs/src/buffer.ts:50
↓ 2 callersMethodtakeUntil
(notifier: ObservableValue<any>)
packages/observable-polyfill/src/index.ts:628
↓ 2 callersFunctiontemporaryRoot
()
packages/migrate/test/harness/harness.spec.ts:217
↓ 2 callersFunctionterminate
(kind: 'complete' | 'error', error?: unknown)
packages/rxjs/src/group-by.ts:155
↓ 2 callersFunctionterminateWindows
(kind: 'complete' | 'error', error?: unknown)
packages/rxjs/src/window-toggle.ts:44
↓ 2 callersFunctionterminateWithError
(error: unknown)
packages/rxjs/src/window-toggle.ts:56
↓ 2 callersFunctionterminateWithError
(error: unknown)
packages/rxjs/src/buffer-toggle.ts:39
↓ 2 callersFunctionterminateWithError
(error: unknown)
packages/rxjs/src/window-when.ts:33
↓ 2 callersMethodtoJSON
()
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:1388
↓ 2 callersFunctiontoSubscriptionLog
(subscription: ParsedSubscription)
packages/test/src/marble-parser.ts:314
↓ 2 callersFunctiontoUnsignedLongLong
(value: unknown)
packages/observable-polyfill/src/index.ts:319
↓ 2 callersMethodtoggle
(canScroll = true)
apps/rxjs.dev/src/app/custom-elements/toc/toc.component.ts:112
↓ 2 callersFunctiontokenize
(text, ignoreWords, dictionary)
apps/rxjs.dev/tools/transforms/angular-base-package/processors/generateKeywords.js:118
↓ 2 callersFunctiontranspileMigratedProgram
( input, imports, extraTransformers = [], injectRuntime = true, observationBoundary, modeAwareObse
packages/rxjs/test/ported/tools/generate-port-manifest.mjs:7460
↓ 2 callersFunctiontreeIsErrorFree
(tree: OperatorDecisionTree)
apps/rxjs.dev/src/app/custom-elements/operator-decision-tree/utils.ts:9
↓ 2 callersFunctiontruncate
(value, length)
packages/rxjs/test/ported/tools/generate-failure-tracker.mjs:317
↓ 2 callersFunctiontype_suffix
* @param {import("../tokeniser.js").Tokeniser} tokeniser
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:1127
↓ 2 callersMethodupdateHostClasses
()
apps/rxjs.dev/src/app/app.component.ts:384
↓ 2 callersMethodupdateShell
()
apps/rxjs.dev/src/app/app.component.ts:398
↓ 2 callersFunctionusage
()
scripts/analyze-bundles.mjs:39
↓ 2 callersFunctionv
(e)
apps/rxjs.dev/src/assets/js/prettify.js:20
↓ 2 callersFunctionvalidateBetaVersion
(version)
scripts/release/beta.mjs:123
↓ 2 callersFunctionvalidateOsvExceptions
(source, now = new Date())
scripts/security/check-osv-exceptions.mjs:21
↓ 2 callersFunctionvalidateRxjsVersionRequest
(value)
scripts/analyze-bundles.mjs:70
↓ 2 callersFunctionvalidateUpstreamPath
(filePath, importPaths)
packages/observable-polyfill/test/wpt/lib/provenance.mjs:16
↓ 2 callersFunctionverifyRealmPatterns
(files, reviewedIframeFiles)
packages/observable-polyfill/test/wpt/lib/realm-patterns.mjs:16
↓ 2 callersFunctionverifyRequiredSupportFiles
(testFiles, configuredSupportFiles)
packages/observable-polyfill/test/wpt/lib/dependency-closure.mjs:37
↓ 2 callersFunctionverifyVendoredImport
({ config, provenance, inventory, upstreamRoot, expectationsRoot, })
packages/observable-polyfill/test/wpt/lib/provenance.mjs:64
↓ 2 callersFunctionwaitForDriver
( baseUrl, { attempts = 240, retryDelayMs = 250, requestStatus = fetch, wait = delay, getDiagnostics = ()
packages/rxjs/test/release/safari-driver.mjs:79
↓ 2 callersFunctionwebdriverRequest
({ port, method, pathname, body })
packages/observable-polyfill/test/wpt/lib/browser.mjs:201
↓ 2 callersFunctionwptEnvironmentRoot
(checkoutRoot, config, python)
packages/observable-polyfill/test/wpt/lib/runner.mjs:141
↓ 1 callersMethod#addSubscriber
(subscriber: Subscriber<T>)
packages/rxjs/src/async-subject.ts:29
↓ 1 callersMethod#checkSize
()
packages/rxjs/src/replay-subject.ts:38
↓ 1 callersMethod#close
()
packages/test/src/test-sources.ts:264
↓ 1 callersMethod#createTimer
(callback: unknown, delay: unknown, interval: number | undefined, args: readonly unknown[])
packages/test/src/virtual-time.ts:522
↓ 1 callersMethod#enqueueTimer
(entry: TimerEntry)
packages/test/src/virtual-time.ts:555
↓ 1 callersMethod#errorDestination
(connection: Connection, destination: SubjectLike<T>, error: unknown)
packages/rxjs/src/connectable.ts:143
↓ 1 callersMethod#installAbortSignalTimeout
()
packages/test/src/virtual-time.ts:715
↓ 1 callersMethod#installAnimationFrames
()
packages/test/src/virtual-time.ts:592
↓ 1 callersMethod#installClocks
()
packages/test/src/virtual-time.ts:728
↓ 1 callersMethod#installIdleCallbacks
()
packages/test/src/virtual-time.ts:618
↓ 1 callersMethod#installImmediate
()
packages/test/src/virtual-time.ts:667
↓ 1 callersMethod#installMicrotaskTracking
()
packages/test/src/virtual-time.ts:754
↓ 1 callersMethod#installReportError
()
packages/test/src/virtual-time.ts:773
↓ 1 callersMethod#installTimers
()
packages/test/src/virtual-time.ts:506
↓ 1 callersMethod#materializeExpectedMessage
(message: TestMessage<T>)
packages/test/src/assertions.ts:231
↓ 1 callersMethod#materializeValue
(value: unknown, outerFrame: number)
packages/test/src/assertions.ts:244
↓ 1 callersMethod#runAnimationFrame
()
packages/test/src/virtual-time.ts:606
↓ 1 callersMethod#runIdleOpportunity
()
packages/test/src/virtual-time.ts:642
↓ 1 callersMethod#runThrough
(target: number)
packages/test/src/virtual-time.ts:388
↓ 1 callersMethod#scheduleAgeFlush
()
packages/rxjs/src/replay-subject.ts:26
↓ 1 callersMethod#waitForManualOperations
()
packages/test/src/virtual-time.ts:497
↓ 1 callersFunctionFETCHING_ERROR_CONTENTS
(path: string)
apps/rxjs.dev/src/app/documents/document.service.ts:18
↓ 1 callersFunctionJ
(a,d,f,b,v)
apps/rxjs.dev/src/assets/js/prettify.js:23
↓ 1 callersFunctionT
(a)
apps/rxjs.dev/src/assets/js/prettify.js:18
↓ 1 callersFunctionU
(a,d)
apps/rxjs.dev/src/assets/js/prettify.js:22
↓ 1 callersFunctionV
(a)
apps/rxjs.dev/src/assets/js/prettify.js:23
↓ 1 callersFunction__subscriptionFrame
(marbles, marker, parseTime)
packages/rxjs/test/ported/cold/operators/group-by.spec.ts:1284
↓ 1 callersFunction__subscriptionFrame
(marbles, marker, parseTime)
packages/rxjs/test/ported/platform/operators/group-by.spec.ts:1283
↓ 1 callersFunction__webpack_require__
(moduleId)
packages/observable-polyfill/test/wpt/upstream/resources/webidl2/lib/webidl2.js:3927
↓ 1 callersFunction_main
(args)
apps/rxjs.dev/scripts/test-pwa-score.js:35
↓ 1 callersMethod_subscribe
(subscriber: Subscriber<T>)
packages/rxjs/src/replay-subject.ts:50
↓ 1 callersMethodaccept
(nextOrObserver: Partial<Observer<T>> | ((value: T) => void), error?: (error: any) => void, complete?: () => v
packages/rxjs/src/notification.ts:52
↓ 1 callersFunctionactiveIndices
()
apps/rxjs.dev/src/app/shared/scroll-spy.service.spec.ts:63
↓ 1 callersMethodadapt
(source: string, options?: { readonly fileName?: string })
packages/migrate/src/types.ts:157
↓ 1 callersFunctionadaptArguments
( adapter: ArgumentAdapter, argumentsList: ts.NodeArray<ts.Expression>, factory: ts.NodeFactory, visit
packages/migrate/src/semantics.ts:667
↓ 1 callersFunctionadapterFor
(harness: SkillHarness)
packages/migrate/src/skill-install.ts:169
↓ 1 callersFunctionadd
(code: ContractReadinessAssessment['findings'][number]['code'], path: string, message: string)
packages/migrate/src/schemas.ts:243
↓ 1 callersFunctionaddAsyncModifier
(modifiers, factory)
packages/rxjs/test/ported/tools/generate-port-manifest.mjs:8643
↓ 1 callersMethodaddDocumentMetaTags
(title: string, description: string | null)
apps/rxjs.dev/src/app/layout/doc-viewer/doc-viewer.component.ts:258
↓ 1 callersFunctionaddHandler
(handler)
packages/rxjs/test/ported/cold/observables/from-event-pattern.spec.ts:9
↓ 1 callersFunctionadd_completion_callback
* Add a callback that's triggered when all tests are complete. * * @param {Function} callback - Callback function, called with an * arr
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4249
↓ 1 callersFunctionadd_result_callback
* Add a callback that's triggered when a test result is received. * * @param {Function} callback - Callback function, called with the *
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4232
↓ 1 callersFunctionadd_start_callback
* Add a callback that's triggered when the first :js:class:`Test` is created. * * @param {Function} callback - Callback function. This is ca
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4212
↓ 1 callersFunctionadd_test_state_callback
* Add a callback that's triggered when a test state changes. * * @param {Function} callback - Callback function, called with the * :js:
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4222
↓ 1 callersMethodadvanceBy
Advances by a relative duration and drains work due through that time.
packages/test/src/types.ts:189
↓ 1 callersMethodadvanceTo
(time: TestDuration)
packages/test/src/virtual-time.ts:284
↓ 1 callersMethodadvanceTo
Advances to an absolute virtual timestamp.
packages/test/src/types.ts:191
↓ 1 callersFunctionajaxTimeoutFixture
(config)
packages/rxjs/test/ported/cold/observables/dom/ajax.spec.ts:52
↓ 1 callersFunctionajaxTimeoutFixture
(config)
packages/rxjs/test/ported/platform/observables/dom/ajax.spec.ts:51
↓ 1 callersFunctionallPaths
(root)
scripts/check-package-docs.mjs:95
↓ 1 callersFunctionall_async
* Immediately invoke a "iteratee" function with a series of values in * parallel and invoke a final "done" function when all of the "iteratee"
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:4924
↓ 1 callersFunctionall_complete
()
packages/observable-polyfill/test/wpt/upstream/resources/testharness.js:3927
↓ 1 callersFunctionanalyzeTestSource
( source: string, options: { readonly mode?: MigrationMode; readonly capabilityRegistry?: CapabilityRegist
packages/migrate/src/analyze.ts:14
↓ 1 callersFunctionanalyzerBinary
(toolRequire)
scripts/analyze-bundles.mjs:647
↓ 1 callersFunctionapiOptions
(file: string)
packages/migrate/src/cli.spec.ts:132
← previousnext →501–600 of 2,527, ranked by callers