feat(compose): support any return value for compose method

#207
staltz · Jul 13, 2017 · 330aaba · 330aaba
1 parent 06d7f67
commit 330aaba
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/index.ts b/src/index.ts
@@ -1794,7 +1794,7 @@ export class Stream<T> implements InternalListener<T> {
    * returns a stream as well.
    * @return {Stream}
    */
-  compose<U>(operator: (stream: Stream<T>) => Stream<U>): Stream<U> {
+  compose<U>(operator: (stream: Stream<T>) => U): U {
     return operator(this);
   }