feat(Stream): add mapTo to Stream prototype

staltz · Mar 28, 2016 · 58c83f9 · 58c83f9
1 parent f73bc8e
commit 58c83f9
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Stream.ts b/src/Stream.ts
@@ -3,6 +3,7 @@ import {Producer} from './Producer';
 import {InternalListener} from './InternalListener';
 import {InternalProducer} from './InternalProducer';
 import {MapOperator} from './operator/MapOperator';
+import {MapToOperator} from './operator/MapToOperator';
 import {FilterOperator} from './operator/FilterOperator';
 import {TakeOperator} from './operator/TakeOperator';
 import {DropOperator} from './operator/DropOperator';
@@ -171,6 +172,10 @@ export class Stream<T> implements InternalListener<T> {
     return new Stream<U>(new MapOperator(project, this));
   }
 
+  mapTo<U>(projectedValue: U): Stream<U> {
+    return new Stream<U>(new MapToOperator(projectedValue, this));
+  }
+
   filter(predicate: (t: T) => boolean): Stream<T> {
     return new Stream<T>(new FilterOperator(predicate, this));
   }