@metrichor/epi2me-web - npm Package Compare versions

Comparing version 4.0.4433300 to 4.0.4438332

cjs/operators.js

@@ -26,11 +26,11 @@ "use strict";
     return (source$) => {
-        return new rxjs_1.Observable(({ next, complete, error }) => {
+        return new rxjs_1.Observable((subscriber) => {
             source$.subscribe({
                 next(value) {
                     if (ts_runtime_typecheck_1.isDefined(value)) {
-                        next(value);
+                        subscriber.next(value);
                     }
                 },
-                complete,
-                error,
+                complete: subscriber.complete.bind(subscriber),
+                error: subscriber.error.bind(subscriber),
             });
@@ -59,3 +59,3 @@ });
         let previous = {};
-        return new rxjs_1.Observable(({ next, complete, error }) => {
+        return new rxjs_1.Observable((subscriber) => {
             source$.subscribe({
@@ -70,6 +70,6 @@ next(record) {
                     previous = record;
-                    next(output);
+                    subscriber.next(output);
                 },
-                complete,
-                error,
+                complete: subscriber.complete.bind(subscriber),
+                error: subscriber.error.bind(subscriber),
             });
@@ -76,0 +76,0 @@ });

esm/operators.js

@@ -23,11 +23,11 @@ import { Observable } from 'rxjs';
     return (source$) => {
-        return new Observable(({ next, complete, error }) => {
+        return new Observable((subscriber) => {
             source$.subscribe({
                 next(value) {
                     if (isDefined(value)) {
-                        next(value);
+                        subscriber.next(value);
                     }
                 },
-                complete,
-                error,
+                complete: subscriber.complete.bind(subscriber),
+                error: subscriber.error.bind(subscriber),
             });
@@ -55,3 +55,3 @@ });
         let previous = {};
-        return new Observable(({ next, complete, error }) => {
+        return new Observable((subscriber) => {
             source$.subscribe({
@@ -66,6 +66,6 @@ next(record) {
                     previous = record;
-                    next(output);
+                    subscriber.next(output);
                 },
-                complete,
-                error,
+                complete: subscriber.complete.bind(subscriber),
+                error: subscriber.error.bind(subscriber),
             });
@@ -72,0 +72,0 @@ });

package.json

@@ -12,3 +12,3 @@ {
   "private": false,
-  "version": "4.0.4433300",
+  "version": "4.0.4438332",
   "main": "cjs/index-web.js",
@@ -15,0 +15,0 @@ "module": "esm/index-web.js",

No alert changes

Improved metrics

Total package byte prevSize

2404174

increased by0.01%

No dependency changes