perf(Stream): speed up Stream next, error, complete handlers

By avoiding an array copy operation if not needed.
staltz · Feb 3, 2017 · b32ffe3 · b32ffe3
1 parent 04031c6
commit b32ffe3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -1220,7 +1220,7 @@ export class Stream<T> implements InternalListener<T> {
     const a = this._ils;
     const L = a.length;
     if (this._d) this._dl._n(t);
-    if (L == 1) a[0]._n(t); else {
+    if (L == 1) a[0]._n(t); else if (L == 0) return; else {
       const b = cp(a);
       for (let i = 0; i < L; i++) b[i]._n(t);
     }
@@ -1233,7 +1233,7 @@ export class Stream<T> implements InternalListener<T> {
     const L = a.length;
     this._x();
     if (this._d) this._dl._e(err);
-    if (L == 1) a[0]._e(err); else {
+    if (L == 1) a[0]._e(err); else if (L == 0) return; else {
       const b = cp(a);
       for (let i = 0; i < L; i++) b[i]._e(err);
     }
@@ -1245,7 +1245,7 @@ export class Stream<T> implements InternalListener<T> {
     const L = a.length;
     this._x();
     if (this._d) this._dl._c();
-    if (L == 1) a[0]._c(); else {
+    if (L == 1) a[0]._c(); else if (L == 0) return; else {
       const b = cp(a);
       for (let i = 0; i < L; i++) b[i]._c();
     }