From f73bc8ea5f58a55d242a7e5df2f054dbb6f7e35f Mon Sep 17 00:00:00 2001
From: Tylor Steinberger <tlsteinberger167@gmail.com>
Date: Mon, 28 Mar 2016 09:36:39 -0400
Subject: [PATCH] feat(mapTo): implement mapTo

---
 src/operator/MapToOperator.ts | 38 +++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)
 create mode 100644 src/operator/MapToOperator.ts

diff --git a/src/operator/MapToOperator.ts b/src/operator/MapToOperator.ts
new file mode 100644
index 0000000..04c9692
--- /dev/null
+++ b/src/operator/MapToOperator.ts
@@ -0,0 +1,38 @@
+import {InternalListener} from '../InternalListener';
+import {Operator} from '../Operator';
+import {Stream} from '../Stream';
+import {emptyListener} from '../utils/emptyListener';
+
+export class Proxy<T, R> implements InternalListener<T> {
+  constructor(public out: Stream<R>,
+              public op: MapToOperator<T, R>) {
+  }
+
+  _n(t: T) {
+    this.out._n(this.op.projectedValue);
+  }
+
+  _e(err: any) {
+    this.out._e(err);
+  }
+
+  _c() {
+    this.out._c();
+  }
+}
+
+export class MapToOperator<T, R> implements Operator<T, R> {
+  public proxy: InternalListener<T> = emptyListener;
+
+  constructor(public projectedValue: R,
+              public ins: Stream<T>) {
+  }
+
+  _start(out: Stream<R>): void {
+    this.ins._add(this.proxy = new Proxy(out, this));
+  }
+
+  _stop(): void {
+    this.ins._remove(this.proxy);
+  }
+}