diff --git a/src/operators/map.ts b/src/operators/map.ts
index 7005351..287c595 100644
--- a/src/operators/map.ts
+++ b/src/operators/map.ts
@@ -2,7 +2,22 @@ import { Observable } from '../Observable';
 import { OperatorFunction } from './types';
 
 export function map<T, R>(project: (value: T) => R): OperatorFunction<T, R> {
-  void Observable;
-  void project;
-  throw new Error('TODO');
+  return source => {
+    return new Observable(observer => {
+      const next = (value: T) => {
+        try {
+          const result = project(value);
+          observer.next(result);
+        } catch (e) {
+          observer.error(e);
+        }
+      };
+
+      return source.subscribe({
+        next,
+        error: err => observer.error(err),
+        complete: () => observer.complete(),
+      });
+    });
+  };
 }