From d55b767039605256c736166a942a9138e3eacfd7 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sun, 29 Jun 2025 11:49:28 -0700 Subject: remove dev node_modules (oops) --- .../src/internal/util/ArgumentOutOfRangeError.ts | 28 ------- node_modules/rxjs/src/internal/util/EmptyError.ts | 30 ------- node_modules/rxjs/src/internal/util/Immediate.ts | 45 ---------- .../rxjs/src/internal/util/NotFoundError.ts | 26 ------ .../src/internal/util/ObjectUnsubscribedError.ts | 29 ------- .../rxjs/src/internal/util/SequenceError.ts | 26 ------ .../rxjs/src/internal/util/UnsubscriptionError.ts | 30 ------- node_modules/rxjs/src/internal/util/applyMixins.ts | 10 --- node_modules/rxjs/src/internal/util/args.ts | 19 ----- .../rxjs/src/internal/util/argsArgArrayOrObject.ts | 30 ------- .../rxjs/src/internal/util/argsOrArgArray.ts | 9 -- node_modules/rxjs/src/internal/util/arrRemove.ts | 11 --- .../rxjs/src/internal/util/createErrorClass.ts | 20 ----- .../rxjs/src/internal/util/createObject.ts | 3 - .../rxjs/src/internal/util/errorContext.ts | 42 ---------- .../rxjs/src/internal/util/executeSchedule.ts | 44 ---------- node_modules/rxjs/src/internal/util/identity.ts | 45 ---------- node_modules/rxjs/src/internal/util/isArrayLike.ts | 1 - .../rxjs/src/internal/util/isAsyncIterable.ts | 5 -- node_modules/rxjs/src/internal/util/isDate.ts | 10 --- node_modules/rxjs/src/internal/util/isFunction.ts | 7 -- .../rxjs/src/internal/util/isInteropObservable.ts | 8 -- node_modules/rxjs/src/internal/util/isIterable.ts | 7 -- .../rxjs/src/internal/util/isObservable.ts | 13 --- node_modules/rxjs/src/internal/util/isPromise.ts | 9 -- .../rxjs/src/internal/util/isReadableStreamLike.ts | 23 ------ node_modules/rxjs/src/internal/util/isScheduler.ts | 6 -- node_modules/rxjs/src/internal/util/lift.ts | 32 -------- .../rxjs/src/internal/util/mapOneOrManyArgs.ts | 16 ---- node_modules/rxjs/src/internal/util/noop.ts | 2 - node_modules/rxjs/src/internal/util/not.ts | 3 - node_modules/rxjs/src/internal/util/pipe.ts | 95 ---------------------- .../rxjs/src/internal/util/reportUnhandledError.ts | 24 ------ .../rxjs/src/internal/util/subscribeToArray.ts | 12 --- .../src/internal/util/throwUnobservableError.ts | 12 --- node_modules/rxjs/src/internal/util/workarounds.ts | 7 -- 36 files changed, 739 deletions(-) delete mode 100644 node_modules/rxjs/src/internal/util/ArgumentOutOfRangeError.ts delete mode 100644 node_modules/rxjs/src/internal/util/EmptyError.ts delete mode 100644 node_modules/rxjs/src/internal/util/Immediate.ts delete mode 100644 node_modules/rxjs/src/internal/util/NotFoundError.ts delete mode 100644 node_modules/rxjs/src/internal/util/ObjectUnsubscribedError.ts delete mode 100644 node_modules/rxjs/src/internal/util/SequenceError.ts delete mode 100644 node_modules/rxjs/src/internal/util/UnsubscriptionError.ts delete mode 100644 node_modules/rxjs/src/internal/util/applyMixins.ts delete mode 100644 node_modules/rxjs/src/internal/util/args.ts delete mode 100644 node_modules/rxjs/src/internal/util/argsArgArrayOrObject.ts delete mode 100644 node_modules/rxjs/src/internal/util/argsOrArgArray.ts delete mode 100644 node_modules/rxjs/src/internal/util/arrRemove.ts delete mode 100644 node_modules/rxjs/src/internal/util/createErrorClass.ts delete mode 100644 node_modules/rxjs/src/internal/util/createObject.ts delete mode 100644 node_modules/rxjs/src/internal/util/errorContext.ts delete mode 100644 node_modules/rxjs/src/internal/util/executeSchedule.ts delete mode 100644 node_modules/rxjs/src/internal/util/identity.ts delete mode 100644 node_modules/rxjs/src/internal/util/isArrayLike.ts delete mode 100644 node_modules/rxjs/src/internal/util/isAsyncIterable.ts delete mode 100644 node_modules/rxjs/src/internal/util/isDate.ts delete mode 100644 node_modules/rxjs/src/internal/util/isFunction.ts delete mode 100644 node_modules/rxjs/src/internal/util/isInteropObservable.ts delete mode 100644 node_modules/rxjs/src/internal/util/isIterable.ts delete mode 100644 node_modules/rxjs/src/internal/util/isObservable.ts delete mode 100644 node_modules/rxjs/src/internal/util/isPromise.ts delete mode 100644 node_modules/rxjs/src/internal/util/isReadableStreamLike.ts delete mode 100644 node_modules/rxjs/src/internal/util/isScheduler.ts delete mode 100644 node_modules/rxjs/src/internal/util/lift.ts delete mode 100644 node_modules/rxjs/src/internal/util/mapOneOrManyArgs.ts delete mode 100644 node_modules/rxjs/src/internal/util/noop.ts delete mode 100644 node_modules/rxjs/src/internal/util/not.ts delete mode 100644 node_modules/rxjs/src/internal/util/pipe.ts delete mode 100644 node_modules/rxjs/src/internal/util/reportUnhandledError.ts delete mode 100644 node_modules/rxjs/src/internal/util/subscribeToArray.ts delete mode 100644 node_modules/rxjs/src/internal/util/throwUnobservableError.ts delete mode 100644 node_modules/rxjs/src/internal/util/workarounds.ts (limited to 'node_modules/rxjs/src/internal/util') diff --git a/node_modules/rxjs/src/internal/util/ArgumentOutOfRangeError.ts b/node_modules/rxjs/src/internal/util/ArgumentOutOfRangeError.ts deleted file mode 100644 index 9a89d76..0000000 --- a/node_modules/rxjs/src/internal/util/ArgumentOutOfRangeError.ts +++ /dev/null @@ -1,28 +0,0 @@ -import { createErrorClass } from './createErrorClass'; - -export interface ArgumentOutOfRangeError extends Error {} - -export interface ArgumentOutOfRangeErrorCtor { - /** - * @deprecated Internal implementation detail. Do not construct error instances. - * Cannot be tagged as internal: https://github.com/ReactiveX/rxjs/issues/6269 - */ - new (): ArgumentOutOfRangeError; -} - -/** - * An error thrown when an element was queried at a certain index of an - * Observable, but no such index or position exists in that sequence. - * - * @see {@link elementAt} - * @see {@link take} - * @see {@link takeLast} - */ -export const ArgumentOutOfRangeError: ArgumentOutOfRangeErrorCtor = createErrorClass( - (_super) => - function ArgumentOutOfRangeErrorImpl(this: any) { - _super(this); - this.name = 'ArgumentOutOfRangeError'; - this.message = 'argument out of range'; - } -); diff --git a/node_modules/rxjs/src/internal/util/EmptyError.ts b/node_modules/rxjs/src/internal/util/EmptyError.ts deleted file mode 100644 index eb2c5e3..0000000 --- a/node_modules/rxjs/src/internal/util/EmptyError.ts +++ /dev/null @@ -1,30 +0,0 @@ -import { createErrorClass } from './createErrorClass'; - -export interface EmptyError extends Error {} - -export interface EmptyErrorCtor { - /** - * @deprecated Internal implementation detail. Do not construct error instances. - * Cannot be tagged as internal: https://github.com/ReactiveX/rxjs/issues/6269 - */ - new (): EmptyError; -} - -/** - * An error thrown when an Observable or a sequence was queried but has no - * elements. - * - * @see {@link first} - * @see {@link last} - * @see {@link single} - * @see {@link firstValueFrom} - * @see {@link lastValueFrom} - */ -export const EmptyError: EmptyErrorCtor = createErrorClass( - (_super) => - function EmptyErrorImpl(this: any) { - _super(this); - this.name = 'EmptyError'; - this.message = 'no elements in sequence'; - } -); diff --git a/node_modules/rxjs/src/internal/util/Immediate.ts b/node_modules/rxjs/src/internal/util/Immediate.ts deleted file mode 100644 index f01f546..0000000 --- a/node_modules/rxjs/src/internal/util/Immediate.ts +++ /dev/null @@ -1,45 +0,0 @@ -let nextHandle = 1; -// The promise needs to be created lazily otherwise it won't be patched by Zones -let resolved: Promise; -const activeHandles: { [key: number]: any } = {}; - -/** - * Finds the handle in the list of active handles, and removes it. - * Returns `true` if found, `false` otherwise. Used both to clear - * Immediate scheduled tasks, and to identify if a task should be scheduled. - */ -function findAndClearHandle(handle: number): boolean { - if (handle in activeHandles) { - delete activeHandles[handle]; - return true; - } - return false; -} - -/** - * Helper functions to schedule and unschedule microtasks. - */ -export const Immediate = { - setImmediate(cb: () => void): number { - const handle = nextHandle++; - activeHandles[handle] = true; - if (!resolved) { - resolved = Promise.resolve(); - } - resolved.then(() => findAndClearHandle(handle) && cb()); - return handle; - }, - - clearImmediate(handle: number): void { - findAndClearHandle(handle); - }, -}; - -/** - * Used for internal testing purposes only. Do not export from library. - */ -export const TestTools = { - pending() { - return Object.keys(activeHandles).length; - } -}; diff --git a/node_modules/rxjs/src/internal/util/NotFoundError.ts b/node_modules/rxjs/src/internal/util/NotFoundError.ts deleted file mode 100644 index ecd213f..0000000 --- a/node_modules/rxjs/src/internal/util/NotFoundError.ts +++ /dev/null @@ -1,26 +0,0 @@ -import { createErrorClass } from './createErrorClass'; - -export interface NotFoundError extends Error {} - -export interface NotFoundErrorCtor { - /** - * @deprecated Internal implementation detail. Do not construct error instances. - * Cannot be tagged as internal: https://github.com/ReactiveX/rxjs/issues/6269 - */ - new (message: string): NotFoundError; -} - -/** - * An error thrown when a value or values are missing from an - * observable sequence. - * - * @see {@link operators/single} - */ -export const NotFoundError: NotFoundErrorCtor = createErrorClass( - (_super) => - function NotFoundErrorImpl(this: any, message: string) { - _super(this); - this.name = 'NotFoundError'; - this.message = message; - } -); diff --git a/node_modules/rxjs/src/internal/util/ObjectUnsubscribedError.ts b/node_modules/rxjs/src/internal/util/ObjectUnsubscribedError.ts deleted file mode 100644 index 5e833f9..0000000 --- a/node_modules/rxjs/src/internal/util/ObjectUnsubscribedError.ts +++ /dev/null @@ -1,29 +0,0 @@ -import { createErrorClass } from './createErrorClass'; - -export interface ObjectUnsubscribedError extends Error {} - -export interface ObjectUnsubscribedErrorCtor { - /** - * @deprecated Internal implementation detail. Do not construct error instances. - * Cannot be tagged as internal: https://github.com/ReactiveX/rxjs/issues/6269 - */ - new (): ObjectUnsubscribedError; -} - -/** - * An error thrown when an action is invalid because the object has been - * unsubscribed. - * - * @see {@link Subject} - * @see {@link BehaviorSubject} - * - * @class ObjectUnsubscribedError - */ -export const ObjectUnsubscribedError: ObjectUnsubscribedErrorCtor = createErrorClass( - (_super) => - function ObjectUnsubscribedErrorImpl(this: any) { - _super(this); - this.name = 'ObjectUnsubscribedError'; - this.message = 'object unsubscribed'; - } -); diff --git a/node_modules/rxjs/src/internal/util/SequenceError.ts b/node_modules/rxjs/src/internal/util/SequenceError.ts deleted file mode 100644 index 06483d0..0000000 --- a/node_modules/rxjs/src/internal/util/SequenceError.ts +++ /dev/null @@ -1,26 +0,0 @@ -import { createErrorClass } from './createErrorClass'; - -export interface SequenceError extends Error {} - -export interface SequenceErrorCtor { - /** - * @deprecated Internal implementation detail. Do not construct error instances. - * Cannot be tagged as internal: https://github.com/ReactiveX/rxjs/issues/6269 - */ - new (message: string): SequenceError; -} - -/** - * An error thrown when something is wrong with the sequence of - * values arriving on the observable. - * - * @see {@link operators/single} - */ -export const SequenceError: SequenceErrorCtor = createErrorClass( - (_super) => - function SequenceErrorImpl(this: any, message: string) { - _super(this); - this.name = 'SequenceError'; - this.message = message; - } -); diff --git a/node_modules/rxjs/src/internal/util/UnsubscriptionError.ts b/node_modules/rxjs/src/internal/util/UnsubscriptionError.ts deleted file mode 100644 index cd7d09f..0000000 --- a/node_modules/rxjs/src/internal/util/UnsubscriptionError.ts +++ /dev/null @@ -1,30 +0,0 @@ -import { createErrorClass } from './createErrorClass'; - -export interface UnsubscriptionError extends Error { - readonly errors: any[]; -} - -export interface UnsubscriptionErrorCtor { - /** - * @deprecated Internal implementation detail. Do not construct error instances. - * Cannot be tagged as internal: https://github.com/ReactiveX/rxjs/issues/6269 - */ - new (errors: any[]): UnsubscriptionError; -} - -/** - * An error thrown when one or more errors have occurred during the - * `unsubscribe` of a {@link Subscription}. - */ -export const UnsubscriptionError: UnsubscriptionErrorCtor = createErrorClass( - (_super) => - function UnsubscriptionErrorImpl(this: any, errors: (Error | string)[]) { - _super(this); - this.message = errors - ? `${errors.length} errors occurred during unsubscription: -${errors.map((err, i) => `${i + 1}) ${err.toString()}`).join('\n ')}` - : ''; - this.name = 'UnsubscriptionError'; - this.errors = errors; - } -); diff --git a/node_modules/rxjs/src/internal/util/applyMixins.ts b/node_modules/rxjs/src/internal/util/applyMixins.ts deleted file mode 100644 index 7c1ed24..0000000 --- a/node_modules/rxjs/src/internal/util/applyMixins.ts +++ /dev/null @@ -1,10 +0,0 @@ -export function applyMixins(derivedCtor: any, baseCtors: any[]) { - for (let i = 0, len = baseCtors.length; i < len; i++) { - const baseCtor = baseCtors[i]; - const propertyKeys = Object.getOwnPropertyNames(baseCtor.prototype); - for (let j = 0, len2 = propertyKeys.length; j < len2; j++) { - const name = propertyKeys[j]; - derivedCtor.prototype[name] = baseCtor.prototype[name]; - } - } -} \ No newline at end of file diff --git a/node_modules/rxjs/src/internal/util/args.ts b/node_modules/rxjs/src/internal/util/args.ts deleted file mode 100644 index 0ce104b..0000000 --- a/node_modules/rxjs/src/internal/util/args.ts +++ /dev/null @@ -1,19 +0,0 @@ -import { SchedulerLike } from '../types'; -import { isFunction } from './isFunction'; -import { isScheduler } from './isScheduler'; - -function last(arr: T[]): T | undefined { - return arr[arr.length - 1]; -} - -export function popResultSelector(args: any[]): ((...args: unknown[]) => unknown) | undefined { - return isFunction(last(args)) ? args.pop() : undefined; -} - -export function popScheduler(args: any[]): SchedulerLike | undefined { - return isScheduler(last(args)) ? args.pop() : undefined; -} - -export function popNumber(args: any[], defaultValue: number): number { - return typeof last(args) === 'number' ? args.pop()! : defaultValue; -} diff --git a/node_modules/rxjs/src/internal/util/argsArgArrayOrObject.ts b/node_modules/rxjs/src/internal/util/argsArgArrayOrObject.ts deleted file mode 100644 index 483bef9..0000000 --- a/node_modules/rxjs/src/internal/util/argsArgArrayOrObject.ts +++ /dev/null @@ -1,30 +0,0 @@ -const { isArray } = Array; -const { getPrototypeOf, prototype: objectProto, keys: getKeys } = Object; - -/** - * Used in functions where either a list of arguments, a single array of arguments, or a - * dictionary of arguments can be returned. Returns an object with an `args` property with - * the arguments in an array, if it is a dictionary, it will also return the `keys` in another - * property. - */ -export function argsArgArrayOrObject>(args: T[] | [O] | [T[]]): { args: T[]; keys: string[] | null } { - if (args.length === 1) { - const first = args[0]; - if (isArray(first)) { - return { args: first, keys: null }; - } - if (isPOJO(first)) { - const keys = getKeys(first); - return { - args: keys.map((key) => first[key]), - keys, - }; - } - } - - return { args: args as T[], keys: null }; -} - -function isPOJO(obj: any): obj is object { - return obj && typeof obj === 'object' && getPrototypeOf(obj) === objectProto; -} diff --git a/node_modules/rxjs/src/internal/util/argsOrArgArray.ts b/node_modules/rxjs/src/internal/util/argsOrArgArray.ts deleted file mode 100644 index b0096ce..0000000 --- a/node_modules/rxjs/src/internal/util/argsOrArgArray.ts +++ /dev/null @@ -1,9 +0,0 @@ -const { isArray } = Array; - -/** - * Used in operators and functions that accept either a list of arguments, or an array of arguments - * as a single argument. - */ -export function argsOrArgArray(args: (T | T[])[]): T[] { - return args.length === 1 && isArray(args[0]) ? args[0] : (args as T[]); -} diff --git a/node_modules/rxjs/src/internal/util/arrRemove.ts b/node_modules/rxjs/src/internal/util/arrRemove.ts deleted file mode 100644 index 51a76cd..0000000 --- a/node_modules/rxjs/src/internal/util/arrRemove.ts +++ /dev/null @@ -1,11 +0,0 @@ -/** - * Removes an item from an array, mutating it. - * @param arr The array to remove the item from - * @param item The item to remove - */ -export function arrRemove(arr: T[] | undefined | null, item: T) { - if (arr) { - const index = arr.indexOf(item); - 0 <= index && arr.splice(index, 1); - } -} diff --git a/node_modules/rxjs/src/internal/util/createErrorClass.ts b/node_modules/rxjs/src/internal/util/createErrorClass.ts deleted file mode 100644 index e354fd3..0000000 --- a/node_modules/rxjs/src/internal/util/createErrorClass.ts +++ /dev/null @@ -1,20 +0,0 @@ -/** - * Used to create Error subclasses until the community moves away from ES5. - * - * This is because compiling from TypeScript down to ES5 has issues with subclassing Errors - * as well as other built-in types: https://github.com/Microsoft/TypeScript/issues/12123 - * - * @param createImpl A factory function to create the actual constructor implementation. The returned - * function should be a named function that calls `_super` internally. - */ -export function createErrorClass(createImpl: (_super: any) => any): T { - const _super = (instance: any) => { - Error.call(instance); - instance.stack = new Error().stack; - }; - - const ctorFunc = createImpl(_super); - ctorFunc.prototype = Object.create(Error.prototype); - ctorFunc.prototype.constructor = ctorFunc; - return ctorFunc; -} diff --git a/node_modules/rxjs/src/internal/util/createObject.ts b/node_modules/rxjs/src/internal/util/createObject.ts deleted file mode 100644 index 0f79f92..0000000 --- a/node_modules/rxjs/src/internal/util/createObject.ts +++ /dev/null @@ -1,3 +0,0 @@ -export function createObject(keys: string[], values: any[]) { - return keys.reduce((result, key, i) => ((result[key] = values[i]), result), {} as any); -} diff --git a/node_modules/rxjs/src/internal/util/errorContext.ts b/node_modules/rxjs/src/internal/util/errorContext.ts deleted file mode 100644 index 6c4ffb1..0000000 --- a/node_modules/rxjs/src/internal/util/errorContext.ts +++ /dev/null @@ -1,42 +0,0 @@ -import { config } from '../config'; - -let context: { errorThrown: boolean; error: any } | null = null; - -/** - * Handles dealing with errors for super-gross mode. Creates a context, in which - * any synchronously thrown errors will be passed to {@link captureError}. Which - * will record the error such that it will be rethrown after the call back is complete. - * TODO: Remove in v8 - * @param cb An immediately executed function. - */ -export function errorContext(cb: () => void) { - if (config.useDeprecatedSynchronousErrorHandling) { - const isRoot = !context; - if (isRoot) { - context = { errorThrown: false, error: null }; - } - cb(); - if (isRoot) { - const { errorThrown, error } = context!; - context = null; - if (errorThrown) { - throw error; - } - } - } else { - // This is the general non-deprecated path for everyone that - // isn't crazy enough to use super-gross mode (useDeprecatedSynchronousErrorHandling) - cb(); - } -} - -/** - * Captures errors only in super-gross mode. - * @param err the error to capture - */ -export function captureError(err: any) { - if (config.useDeprecatedSynchronousErrorHandling && context) { - context.errorThrown = true; - context.error = err; - } -} diff --git a/node_modules/rxjs/src/internal/util/executeSchedule.ts b/node_modules/rxjs/src/internal/util/executeSchedule.ts deleted file mode 100644 index 1bcb990..0000000 --- a/node_modules/rxjs/src/internal/util/executeSchedule.ts +++ /dev/null @@ -1,44 +0,0 @@ -import { Subscription } from '../Subscription'; -import { SchedulerAction, SchedulerLike } from '../types'; - -export function executeSchedule( - parentSubscription: Subscription, - scheduler: SchedulerLike, - work: () => void, - delay: number, - repeat: true -): void; -export function executeSchedule( - parentSubscription: Subscription, - scheduler: SchedulerLike, - work: () => void, - delay?: number, - repeat?: false -): Subscription; - -export function executeSchedule( - parentSubscription: Subscription, - scheduler: SchedulerLike, - work: () => void, - delay = 0, - repeat = false -): Subscription | void { - const scheduleSubscription = scheduler.schedule(function (this: SchedulerAction) { - work(); - if (repeat) { - parentSubscription.add(this.schedule(null, delay)); - } else { - this.unsubscribe(); - } - }, delay); - - parentSubscription.add(scheduleSubscription); - - if (!repeat) { - // Because user-land scheduler implementations are unlikely to properly reuse - // Actions for repeat scheduling, we can't trust that the returned subscription - // will control repeat subscription scenarios. So we're trying to avoid using them - // incorrectly within this library. - return scheduleSubscription; - } -} diff --git a/node_modules/rxjs/src/internal/util/identity.ts b/node_modules/rxjs/src/internal/util/identity.ts deleted file mode 100644 index 0b07958..0000000 --- a/node_modules/rxjs/src/internal/util/identity.ts +++ /dev/null @@ -1,45 +0,0 @@ -/** - * This function takes one parameter and just returns it. Simply put, - * this is like `(x: T): T => x`. - * - * ## Examples - * - * This is useful in some cases when using things like `mergeMap` - * - * ```ts - * import { interval, take, map, range, mergeMap, identity } from 'rxjs'; - * - * const source$ = interval(1000).pipe(take(5)); - * - * const result$ = source$.pipe( - * map(i => range(i)), - * mergeMap(identity) // same as mergeMap(x => x) - * ); - * - * result$.subscribe({ - * next: console.log - * }); - * ``` - * - * Or when you want to selectively apply an operator - * - * ```ts - * import { interval, take, identity } from 'rxjs'; - * - * const shouldLimit = () => Math.random() < 0.5; - * - * const source$ = interval(1000); - * - * const result$ = source$.pipe(shouldLimit() ? take(5) : identity); - * - * result$.subscribe({ - * next: console.log - * }); - * ``` - * - * @param x Any value that is returned by this function - * @returns The value passed as the first parameter to this function - */ -export function identity(x: T): T { - return x; -} diff --git a/node_modules/rxjs/src/internal/util/isArrayLike.ts b/node_modules/rxjs/src/internal/util/isArrayLike.ts deleted file mode 100644 index 6f634d4..0000000 --- a/node_modules/rxjs/src/internal/util/isArrayLike.ts +++ /dev/null @@ -1 +0,0 @@ -export const isArrayLike = ((x: any): x is ArrayLike => x && typeof x.length === 'number' && typeof x !== 'function'); \ No newline at end of file diff --git a/node_modules/rxjs/src/internal/util/isAsyncIterable.ts b/node_modules/rxjs/src/internal/util/isAsyncIterable.ts deleted file mode 100644 index d419dc3..0000000 --- a/node_modules/rxjs/src/internal/util/isAsyncIterable.ts +++ /dev/null @@ -1,5 +0,0 @@ -import { isFunction } from './isFunction'; - -export function isAsyncIterable(obj: any): obj is AsyncIterable { - return Symbol.asyncIterator && isFunction(obj?.[Symbol.asyncIterator]); -} diff --git a/node_modules/rxjs/src/internal/util/isDate.ts b/node_modules/rxjs/src/internal/util/isDate.ts deleted file mode 100644 index ed09ffb..0000000 --- a/node_modules/rxjs/src/internal/util/isDate.ts +++ /dev/null @@ -1,10 +0,0 @@ -/** - * Checks to see if a value is not only a `Date` object, - * but a *valid* `Date` object that can be converted to a - * number. For example, `new Date('blah')` is indeed an - * `instanceof Date`, however it cannot be converted to a - * number. - */ -export function isValidDate(value: any): value is Date { - return value instanceof Date && !isNaN(value as any); -} diff --git a/node_modules/rxjs/src/internal/util/isFunction.ts b/node_modules/rxjs/src/internal/util/isFunction.ts deleted file mode 100644 index 2715f07..0000000 --- a/node_modules/rxjs/src/internal/util/isFunction.ts +++ /dev/null @@ -1,7 +0,0 @@ -/** - * Returns true if the object is a function. - * @param value The value to check - */ -export function isFunction(value: any): value is (...args: any[]) => any { - return typeof value === 'function'; -} diff --git a/node_modules/rxjs/src/internal/util/isInteropObservable.ts b/node_modules/rxjs/src/internal/util/isInteropObservable.ts deleted file mode 100644 index e709b8a..0000000 --- a/node_modules/rxjs/src/internal/util/isInteropObservable.ts +++ /dev/null @@ -1,8 +0,0 @@ -import { InteropObservable } from '../types'; -import { observable as Symbol_observable } from '../symbol/observable'; -import { isFunction } from './isFunction'; - -/** Identifies an input as being Observable (but not necessary an Rx Observable) */ -export function isInteropObservable(input: any): input is InteropObservable { - return isFunction(input[Symbol_observable]); -} diff --git a/node_modules/rxjs/src/internal/util/isIterable.ts b/node_modules/rxjs/src/internal/util/isIterable.ts deleted file mode 100644 index 9b492b3..0000000 --- a/node_modules/rxjs/src/internal/util/isIterable.ts +++ /dev/null @@ -1,7 +0,0 @@ -import { iterator as Symbol_iterator } from '../symbol/iterator'; -import { isFunction } from './isFunction'; - -/** Identifies an input as being an Iterable */ -export function isIterable(input: any): input is Iterable { - return isFunction(input?.[Symbol_iterator]); -} diff --git a/node_modules/rxjs/src/internal/util/isObservable.ts b/node_modules/rxjs/src/internal/util/isObservable.ts deleted file mode 100644 index 8df8f32..0000000 --- a/node_modules/rxjs/src/internal/util/isObservable.ts +++ /dev/null @@ -1,13 +0,0 @@ -/** prettier */ -import { Observable } from '../Observable'; -import { isFunction } from './isFunction'; - -/** - * Tests to see if the object is an RxJS {@link Observable} - * @param obj the object to test - */ -export function isObservable(obj: any): obj is Observable { - // The !! is to ensure that this publicly exposed function returns - // `false` if something like `null` or `0` is passed. - return !!obj && (obj instanceof Observable || (isFunction(obj.lift) && isFunction(obj.subscribe))); -} diff --git a/node_modules/rxjs/src/internal/util/isPromise.ts b/node_modules/rxjs/src/internal/util/isPromise.ts deleted file mode 100644 index 0baef64..0000000 --- a/node_modules/rxjs/src/internal/util/isPromise.ts +++ /dev/null @@ -1,9 +0,0 @@ -import { isFunction } from "./isFunction"; - -/** - * Tests to see if the object is "thennable". - * @param value the object to test - */ -export function isPromise(value: any): value is PromiseLike { - return isFunction(value?.then); -} diff --git a/node_modules/rxjs/src/internal/util/isReadableStreamLike.ts b/node_modules/rxjs/src/internal/util/isReadableStreamLike.ts deleted file mode 100644 index 87b9c15..0000000 --- a/node_modules/rxjs/src/internal/util/isReadableStreamLike.ts +++ /dev/null @@ -1,23 +0,0 @@ -import { ReadableStreamLike } from '../types'; -import { isFunction } from './isFunction'; - -export async function* readableStreamLikeToAsyncGenerator(readableStream: ReadableStreamLike): AsyncGenerator { - const reader = readableStream.getReader(); - try { - while (true) { - const { value, done } = await reader.read(); - if (done) { - return; - } - yield value!; - } - } finally { - reader.releaseLock(); - } -} - -export function isReadableStreamLike(obj: any): obj is ReadableStreamLike { - // We don't want to use instanceof checks because they would return - // false for instances from another Realm, like an