rxjs - npm Package Compare versions

Comparing version 7.5.7 to 7.6.0

dist/cjs/index.js

@@ -15,4 +15,4 @@ "use strict";
 exports.filter = exports.expand = exports.exhaustMap = exports.exhaustAll = exports.exhaust = exports.every = exports.endWith = exports.elementAt = exports.distinctUntilKeyChanged = exports.distinctUntilChanged = exports.distinct = exports.dematerialize = exports.delayWhen = exports.delay = exports.defaultIfEmpty = exports.debounceTime = exports.debounce = exports.count = exports.connect = exports.concatWith = exports.concatMapTo = exports.concatMap = exports.concatAll = exports.combineLatestWith = exports.combineLatestAll = exports.combineAll = exports.catchError = exports.bufferWhen = exports.bufferToggle = exports.bufferTime = exports.bufferCount = exports.buffer = exports.auditTime = exports.audit = exports.config = exports.NEVER = exports.EMPTY = exports.scheduled = exports.zip = exports.using = exports.timer = exports.throwError = exports.range = exports.race = exports.partition = exports.pairs = exports.onErrorResumeNext = exports.of = exports.never = exports.merge = void 0;
-exports.switchMapTo = exports.switchMap = exports.switchAll = exports.subscribeOn = exports.startWith = exports.skipWhile = exports.skipUntil = exports.skipLast = exports.skip = exports.single = exports.shareReplay = exports.share = exports.sequenceEqual = exports.scan = exports.sampleTime = exports.sample = exports.refCount = exports.retryWhen = exports.retry = exports.repeatWhen = exports.repeat = exports.reduce = exports.raceWith = exports.publishReplay = exports.publishLast = exports.publishBehavior = exports.publish = exports.pluck = exports.pairwise = exports.observeOn = exports.multicast = exports.min = exports.mergeWith = exports.mergeScan = exports.mergeMapTo = exports.mergeMap = exports.flatMap = exports.mergeAll = exports.max = exports.materialize = exports.mapTo = exports.map = exports.last = exports.isEmpty = exports.ignoreElements = exports.groupBy = exports.first = exports.findIndex = exports.find = exports.finalize = void 0;
-exports.zipWith = exports.zipAll = exports.withLatestFrom = exports.windowWhen = exports.windowToggle = exports.windowTime = exports.windowCount = exports.window = exports.toArray = exports.timestamp = exports.timeoutWith = exports.timeout = exports.timeInterval = exports.throwIfEmpty = exports.throttleTime = exports.throttle = exports.tap = exports.takeWhile = exports.takeUntil = exports.takeLast = exports.take = exports.switchScan = void 0;
+exports.switchMap = exports.switchAll = exports.subscribeOn = exports.startWith = exports.skipWhile = exports.skipUntil = exports.skipLast = exports.skip = exports.single = exports.shareReplay = exports.share = exports.sequenceEqual = exports.scan = exports.sampleTime = exports.sample = exports.refCount = exports.retryWhen = exports.retry = exports.repeatWhen = exports.repeat = exports.reduce = exports.raceWith = exports.publishReplay = exports.publishLast = exports.publishBehavior = exports.publish = exports.pluck = exports.pairwise = exports.onErrorResumeNextWith = exports.observeOn = exports.multicast = exports.min = exports.mergeWith = exports.mergeScan = exports.mergeMapTo = exports.mergeMap = exports.flatMap = exports.mergeAll = exports.max = exports.materialize = exports.mapTo = exports.map = exports.last = exports.isEmpty = exports.ignoreElements = exports.groupBy = exports.first = exports.findIndex = exports.find = exports.finalize = void 0;
+exports.zipWith = exports.zipAll = exports.withLatestFrom = exports.windowWhen = exports.windowToggle = exports.windowTime = exports.windowCount = exports.window = exports.toArray = exports.timestamp = exports.timeoutWith = exports.timeout = exports.timeInterval = exports.throwIfEmpty = exports.throttleTime = exports.throttle = exports.tap = exports.takeWhile = exports.takeUntil = exports.takeLast = exports.take = exports.switchScan = exports.switchMapTo = void 0;
 var Observable_1 = require("./internal/Observable");
@@ -255,2 +255,4 @@ Object.defineProperty(exports, "Observable", { enumerable: true, get: function () { return Observable_1.Observable; } });
 Object.defineProperty(exports, "observeOn", { enumerable: true, get: function () { return observeOn_1.observeOn; } });
+var onErrorResumeNextWith_1 = require("./internal/operators/onErrorResumeNextWith");
+Object.defineProperty(exports, "onErrorResumeNextWith", { enumerable: true, get: function () { return onErrorResumeNextWith_1.onErrorResumeNextWith; } });
 var pairwise_1 = require("./internal/operators/pairwise");
@@ -257,0 +259,0 @@ Object.defineProperty(exports, "pairwise", { enumerable: true, get: function () { return pairwise_1.pairwise; } });

dist/cjs/internal/observable/onErrorResumeNext.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.onErrorResumeNext = void 0;
-var empty_1 = require("./empty");
-var onErrorResumeNext_1 = require("../operators/onErrorResumeNext");
+var Observable_1 = require("../Observable");
 var argsOrArgArray_1 = require("../util/argsOrArgArray");
+var OperatorSubscriber_1 = require("../operators/OperatorSubscriber");
+var noop_1 = require("../util/noop");
+var innerFrom_1 = require("./innerFrom");
 function onErrorResumeNext() {
@@ -12,5 +14,27 @@ var sources = [];
     }
-    return onErrorResumeNext_1.onErrorResumeNext(argsOrArgArray_1.argsOrArgArray(sources))(empty_1.EMPTY);
+    var nextSources = argsOrArgArray_1.argsOrArgArray(sources);
+    return new Observable_1.Observable(function (subscriber) {
+        var sourceIndex = 0;
+        var subscribeNext = function () {
+            if (sourceIndex < nextSources.length) {
+                var nextSource = void 0;
+                try {
+                    nextSource = innerFrom_1.innerFrom(nextSources[sourceIndex++]);
+                }
+                catch (err) {
+                    subscribeNext();
+                    return;
+                }
+                var innerSubscriber = new OperatorSubscriber_1.OperatorSubscriber(subscriber, undefined, noop_1.noop, noop_1.noop);
+                nextSource.subscribe(innerSubscriber);
+                innerSubscriber.add(subscribeNext);
+            }
+            else {
+                subscriber.complete();
+            }
+        };
+        subscribeNext();
+    });
 }
 exports.onErrorResumeNext = onErrorResumeNext;
 //# sourceMappingURL=onErrorResumeNext.js.map

dist/cjs/operators/index.js

@@ -122,4 +122,4 @@ "use strict";
 Object.defineProperty(exports, "observeOn", { enumerable: true, get: function () { return observeOn_1.observeOn; } });
-var onErrorResumeNext_1 = require("../internal/operators/onErrorResumeNext");
-Object.defineProperty(exports, "onErrorResumeNext", { enumerable: true, get: function () { return onErrorResumeNext_1.onErrorResumeNext; } });
+var onErrorResumeNextWith_1 = require("../internal/operators/onErrorResumeNextWith");
+Object.defineProperty(exports, "onErrorResumeNext", { enumerable: true, get: function () { return onErrorResumeNextWith_1.onErrorResumeNext; } });
 var pairwise_1 = require("../internal/operators/pairwise");
@@ -126,0 +126,0 @@ Object.defineProperty(exports, "pairwise", { enumerable: true, get: function () { return pairwise_1.pairwise; } });

dist/esm/index.js

@@ -117,2 +117,3 @@ export { Observable } from './internal/Observable';
 export { observeOn } from './internal/operators/observeOn';
+export { onErrorResumeNextWith } from './internal/operators/onErrorResumeNextWith';
 export { pairwise } from './internal/operators/pairwise';
@@ -119,0 +120,0 @@ export { pluck } from './internal/operators/pluck';

dist/esm/internal/observable/onErrorResumeNext.js

@@ -1,7 +0,31 @@
-import { EMPTY } from './empty';
-import { onErrorResumeNext as onErrorResumeNextWith } from '../operators/onErrorResumeNext';
+import { Observable } from '../Observable';
 import { argsOrArgArray } from '../util/argsOrArgArray';
+import { OperatorSubscriber } from '../operators/OperatorSubscriber';
+import { noop } from '../util/noop';
+import { innerFrom } from './innerFrom';
 export function onErrorResumeNext(...sources) {
-    return onErrorResumeNextWith(argsOrArgArray(sources))(EMPTY);
+    const nextSources = argsOrArgArray(sources);
+    return new Observable((subscriber) => {
+        let sourceIndex = 0;
+        const subscribeNext = () => {
+            if (sourceIndex < nextSources.length) {
+                let nextSource;
+                try {
+                    nextSource = innerFrom(nextSources[sourceIndex++]);
+                }
+                catch (err) {
+                    subscribeNext();
+                    return;
+                }
+                const innerSubscriber = new OperatorSubscriber(subscriber, undefined, noop, noop);
+                nextSource.subscribe(innerSubscriber);
+                innerSubscriber.add(subscribeNext);
+            }
+            else {
+                subscriber.complete();
+            }
+        };
+        subscribeNext();
+    });
 }
 //# sourceMappingURL=onErrorResumeNext.js.map

dist/esm/operators/index.js

@@ -59,3 +59,3 @@ export { audit } from '../internal/operators/audit';
 export { observeOn } from '../internal/operators/observeOn';
-export { onErrorResumeNext } from '../internal/operators/onErrorResumeNext';
+export { onErrorResumeNext } from '../internal/operators/onErrorResumeNextWith';
 export { pairwise } from '../internal/operators/pairwise';
@@ -62,0 +62,0 @@ export { partition } from '../internal/operators/partition';

dist/esm5/index.js

@@ -117,2 +117,3 @@ export { Observable } from './internal/Observable';
 export { observeOn } from './internal/operators/observeOn';
+export { onErrorResumeNextWith } from './internal/operators/onErrorResumeNextWith';
 export { pairwise } from './internal/operators/pairwise';
@@ -119,0 +120,0 @@ export { pluck } from './internal/operators/pluck';

dist/esm5/internal/observable/onErrorResumeNext.js

@@ -1,4 +0,6 @@
-import { EMPTY } from './empty';
-import { onErrorResumeNext as onErrorResumeNextWith } from '../operators/onErrorResumeNext';
+import { Observable } from '../Observable';
 import { argsOrArgArray } from '../util/argsOrArgArray';
+import { OperatorSubscriber } from '../operators/OperatorSubscriber';
+import { noop } from '../util/noop';
+import { innerFrom } from './innerFrom';
 export function onErrorResumeNext() {
@@ -9,4 +11,26 @@ var sources = [];
     }
-    return onErrorResumeNextWith(argsOrArgArray(sources))(EMPTY);
+    var nextSources = argsOrArgArray(sources);
+    return new Observable(function (subscriber) {
+        var sourceIndex = 0;
+        var subscribeNext = function () {
+            if (sourceIndex < nextSources.length) {
+                var nextSource = void 0;
+                try {
+                    nextSource = innerFrom(nextSources[sourceIndex++]);
+                }
+                catch (err) {
+                    subscribeNext();
+                    return;
+                }
+                var innerSubscriber = new OperatorSubscriber(subscriber, undefined, noop, noop);
+                nextSource.subscribe(innerSubscriber);
+                innerSubscriber.add(subscribeNext);
+            }
+            else {
+                subscriber.complete();
+            }
+        };
+        subscribeNext();
+    });
 }
 //# sourceMappingURL=onErrorResumeNext.js.map

dist/esm5/operators/index.js

@@ -59,3 +59,3 @@ export { audit } from '../internal/operators/audit';
 export { observeOn } from '../internal/operators/observeOn';
-export { onErrorResumeNext } from '../internal/operators/onErrorResumeNext';
+export { onErrorResumeNext } from '../internal/operators/onErrorResumeNextWith';
 export { pairwise } from '../internal/operators/pairwise';
@@ -62,0 +62,0 @@ export { partition } from '../internal/operators/partition';

dist/types/index.d.ts

@@ -121,2 +121,3 @@ /// <reference path="operators/index.d.ts" />
 export { observeOn } from './internal/operators/observeOn';
+export { onErrorResumeNextWith } from './internal/operators/onErrorResumeNextWith';
 export { pairwise } from './internal/operators/pairwise';
@@ -123,0 +124,0 @@ export { pluck } from './internal/operators/pluck';

dist/types/internal/Observable.d.ts

@@ -50,4 +50,3 @@ import { Operator } from './Operator';
     lift<R>(operator?: Operator<T, R>): Observable<R>;
-    subscribe(observer?: Partial<Observer<T>>): Subscription;
-    subscribe(next: (value: T) => void): Subscription;
+    subscribe(observerOrNext?: Partial<Observer<T>> | ((value: T) => void)): Subscription;
     /** @deprecated Instead of passing separate callback arguments, use an observer argument. Signatures taking separate callback arguments will be removed in v8. Details: https://rxjs.dev/deprecations/subscribe-arguments */
@@ -54,0 +53,0 @@ subscribe(next?: ((value: T) => void) | null, error?: ((error: any) => void) | null, complete?: (() => void) | null): Subscription;

dist/types/internal/operators/tap.d.ts

@@ -7,6 +7,5 @@ import { MonoTypeOperatorFunction, Observer } from '../types';
 }
-export declare function tap<T>(observer?: Partial<TapObserver<T>>): MonoTypeOperatorFunction<T>;
-export declare function tap<T>(next: (value: T) => void): MonoTypeOperatorFunction<T>;
+export declare function tap<T>(observerOrNext?: Partial<TapObserver<T>> | ((value: T) => void)): MonoTypeOperatorFunction<T>;
 /** @deprecated Instead of passing separate callback arguments, use an observer argument. Signatures taking separate callback arguments will be removed in v8. Details: https://rxjs.dev/deprecations/subscribe-arguments */
 export declare function tap<T>(next?: ((value: T) => void) | null, error?: ((error: any) => void) | null, complete?: (() => void) | null): MonoTypeOperatorFunction<T>;
 //# sourceMappingURL=tap.d.ts.map

dist/types/internal/ReplaySubject.d.ts

@@ -41,3 +41,3 @@ import { Subject } from './Subject';
      * @param bufferSize The size of the buffer to replay on subscription
-     * @param windowTime The amount of time the buffered items will say buffered
+     * @param windowTime The amount of time the buffered items will stay buffered
      * @param timestampProvider An object with a `now()` method that provides the current timestamp. This is used to
@@ -44,0 +44,0 @@ * calculate the amount of time something has been buffered.

dist/types/internal/scheduler/timerHandle.d.ts

@@ -1,3 +0,2 @@
-/// <reference types="node" />
-export declare type TimerHandle = number | NodeJS.Timeout;
+export declare type TimerHandle = number | ReturnType<typeof setTimeout>;
 //# sourceMappingURL=timerHandle.d.ts.map

dist/types/internal/symbol/observable.d.ts

@@ -1,3 +0,8 @@
-/** Symbol.observable or a string "@@observable". Used for interop */
+/**
+ * Symbol.observable or a string "@@observable". Used for interop
+ *
+ * @deprecated We will no longer be exporting this symbol in upcoming versions of RxJS.
+ * Instead polyfill and use Symbol.observable directly *or* use https://www.npmjs.com/package/symbol-observable
+ */
 export declare const observable: string | symbol;
 //# sourceMappingURL=observable.d.ts.map

dist/types/operators/index.d.ts

@@ -59,3 +59,3 @@ export { audit } from '../internal/operators/audit';
 export { observeOn } from '../internal/operators/observeOn';
-export { onErrorResumeNext } from '../internal/operators/onErrorResumeNext';
+export { onErrorResumeNext } from '../internal/operators/onErrorResumeNextWith';
 export { pairwise } from '../internal/operators/pairwise';
@@ -62,0 +62,0 @@ export { partition } from '../internal/operators/partition';

package.json

 {
   "name": "rxjs",
-  "version": "7.5.7",
+  "version": "7.6.0",
   "description": "Reactive Extensions for modern JavaScript",
@@ -5,0 +5,0 @@ "main": "./dist/cjs/index.js",

src/index.ts

@@ -158,2 +158,3 @@ //////////////////////////////////////////////////////////
 export { observeOn } from './internal/operators/observeOn';
+export { onErrorResumeNextWith } from './internal/operators/onErrorResumeNextWith';
 export { pairwise } from './internal/operators/pairwise';
@@ -160,0 +161,0 @@ export { pluck } from './internal/operators/pluck';

src/internal/Observable.ts

@@ -74,4 +74,3 @@ import { Operator } from './Operator';
 
-  subscribe(observer?: Partial<Observer<T>>): Subscription;
-  subscribe(next: (value: T) => void): Subscription;
+  subscribe(observerOrNext?: Partial<Observer<T>> | ((value: T) => void)): Subscription;
   /** @deprecated Instead of passing separate callback arguments, use an observer argument. Signatures taking separate callback arguments will be removed in v8. Details: https://rxjs.dev/deprecations/subscribe-arguments */
@@ -78,0 +77,0 @@ subscribe(next?: ((value: T) => void) | null, error?: ((error: any) => void) | null, complete?: (() => void) | null): Subscription;

src/internal/observable/onErrorResumeNext.ts

 import { Observable } from '../Observable';
 import { ObservableInputTuple } from '../types';
-import { EMPTY } from './empty';
-import { onErrorResumeNext as onErrorResumeNextWith } from '../operators/onErrorResumeNext';
 import { argsOrArgArray } from '../util/argsOrArgArray';
+import { OperatorSubscriber } from '../operators/OperatorSubscriber';
+import { noop } from '../util/noop';
+import { innerFrom } from './innerFrom';
 
@@ -78,3 +79,24 @@ /* tslint:disable:max-line-length */
 ): Observable<A[number]> {
-  return onErrorResumeNextWith(argsOrArgArray(sources))(EMPTY);
+  const nextSources: ObservableInputTuple<A> = argsOrArgArray(sources) as any;
+
+  return new Observable((subscriber) => {
+    let sourceIndex = 0;
+    const subscribeNext = () => {
+      if (sourceIndex < nextSources.length) {
+        let nextSource: Observable<A[number]>;
+        try {
+          nextSource = innerFrom(nextSources[sourceIndex++]);
+        } catch (err) {
+          subscribeNext();
+          return;
+        }
+        const innerSubscriber = new OperatorSubscriber(subscriber, undefined, noop, noop);
+        nextSource.subscribe(innerSubscriber);
+        innerSubscriber.add(subscribeNext);
+      } else {
+        subscriber.complete();
+      }
+    };
+    subscribeNext();
+  });
 }

src/internal/operators/scan.ts

@@ -47,3 +47,3 @@ import { OperatorFunction } from '../types';
  *     // Get the average by dividing the sum by the total number
- *     // received so var (which is 1 more than the zero-based index).
+ *     // received so far (which is 1 more than the zero-based index).
  *     map((sum, index) => sum / (index + 1))
@@ -50,0 +50,0 @@ *   )

src/internal/operators/tap.ts

@@ -12,5 +12,3 @@ import { MonoTypeOperatorFunction, Observer } from '../types';
 }
-
-export function tap<T>(observer?: Partial<TapObserver<T>>): MonoTypeOperatorFunction<T>;
-export function tap<T>(next: (value: T) => void): MonoTypeOperatorFunction<T>;
+export function tap<T>(observerOrNext?: Partial<TapObserver<T>> | ((value: T) => void)): MonoTypeOperatorFunction<T>;
 /** @deprecated Instead of passing separate callback arguments, use an observer argument. Signatures taking separate callback arguments will be removed in v8. Details: https://rxjs.dev/deprecations/subscribe-arguments */
@@ -17,0 +15,0 @@ export function tap<T>(

src/internal/ReplaySubject.ts

@@ -43,3 +43,3 @@ import { Subject } from './Subject';
    * @param bufferSize The size of the buffer to replay on subscription
-   * @param windowTime The amount of time the buffered items will say buffered
+   * @param windowTime The amount of time the buffered items will stay buffered
    * @param timestampProvider An object with a `now()` method that provides the current timestamp. This is used to
@@ -46,0 +46,0 @@ * calculate the amount of time something has been buffered.

src/internal/scheduler/timerHandle.ts

@@ -1,1 +0,1 @@
-export type TimerHandle = number | NodeJS.Timeout;
+export type TimerHandle = number | ReturnType<typeof setTimeout>;

src/internal/symbol/observable.ts

@@ -1,2 +0,7 @@
-/** Symbol.observable or a string "@@observable". Used for interop */
+/**
+ * Symbol.observable or a string "@@observable". Used for interop
+ *
+ * @deprecated We will no longer be exporting this symbol in upcoming versions of RxJS.
+ * Instead polyfill and use Symbol.observable directly *or* use https://www.npmjs.com/package/symbol-observable
+ */
 export const observable: string | symbol = (() => (typeof Symbol === 'function' && Symbol.observable) || '@@observable')();

src/operators/index.ts

@@ -60,3 +60,3 @@ /* Operator exports */
 export { observeOn } from '../internal/operators/observeOn';
-export { onErrorResumeNext } from '../internal/operators/onErrorResumeNext';
+export { onErrorResumeNext } from '../internal/operators/onErrorResumeNextWith';
 export { pairwise } from '../internal/operators/pairwise';
@@ -63,0 +63,0 @@ export { partition } from '../internal/operators/partition';

No alert changes

Improved metrics

Total package byte prevSize

4482928

increased by0.05%

Lines of code

57277

increased by0.01%

No dependency changes