Simplify flattened stream error type

clear · May 3, 2024 · 9ac3261 · 9ac3261
1 parent 10e211e
commit 9ac3261
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/src/stream/higher-order.ts b/src/stream/higher-order.ts
@@ -34,7 +34,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
     ): Stream<U, F> {
         const trace = this.trace("flatOp");
 
-        return this.consume(async function* (it) {
+        return this.consume(async function*(it) {
             for await (const atom of it) {
                 const result = filter(atom);
 
@@ -67,7 +67,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
     ): Stream<U, F> {
         this.trace("flatMapAll");
 
-        return this.flatOp(filter, cb, async function* (_atom, stream) {
+        return this.flatOp(filter, cb, async function*(_atom, stream) {
             yield* stream;
         });
     }
@@ -131,10 +131,10 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
      * @note Any atoms that are not nested streams are emitted as-is
      * @group Higher Order
      */
-    flatten(): T extends Stream<infer U, infer V> ? Stream<U, V | E> : Stream<T, E> {
+    flatten(): T extends Stream<infer U, E> ? Stream<U, E> : Stream<T, E> {
         this.trace("flatten");
 
-        return this.consume(async function* (it) {
+        return this.consume(async function*(it) {
             for await (const atom of it) {
                 // Yield errors/unkowns directly
                 if (!isOk(atom)) {
@@ -149,7 +149,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
                     yield atom;
                 }
             }
-        }) as T extends Stream<infer U, infer V> ? Stream<U, V | E> : Stream<T, E>;
+        }) as T extends Stream<infer U, E> ? Stream<U, E> : Stream<T, E>;
     }
 
     /**
@@ -161,7 +161,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
     ): Stream<T, E> {
         this.trace("flatTapAtom");
 
-        return this.flatOp(filter, cb, async function* (atom, stream) {
+        return this.flatOp(filter, cb, async function*(atom, stream) {
             await exhaust(stream);
 
             yield atom;
@@ -193,7 +193,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
      * @group Higher Order
      */
     otherwise(cbOrStream: CallbackOrStream<T, E>): Stream<T, E> {
-        return this.consume(async function* (it) {
+        return this.consume(async function*(it) {
             // Count the items being emitted from the iterator
             let count = 0;
             for await (const atom of it) {
@@ -228,7 +228,7 @@ export class HigherOrderStream<T, E> extends StreamTransforms<T, E> {
      * @group Higher Order
      */
     replaceWith<U, F>(cbOrStream: CallbackOrStream<U, F>): Stream<U, F> {
-        return this.consume(async function* (it) {
+        return this.consume(async function*(it) {
             // Consume all the items in the stream
             await exhaust(it);