Some code sample cleanup

Author: jfairbank

.gitignore

@@ -32,4 +32,4 @@ node_modules
 # Optional REPL history
 .node_repl_history
 Gemfile.lock
-demo/public/assets/bundle.js
+demo/public

code/observables/async/observable-3.js

@@ -1,15 +1,3 @@
-const { Observable } = require('rxjs');
-const axios = require('axios');
-
-Observable.ajax = {
-  get(url) {
-    return Observable.fromPromise(
-      axios.get(`http://localhost:3000${url}`)
-        .then(({ data }) => data)
-    );
-  },
-};
-
 function fetchOrders() {
   return Observable.ajax.get('/orders');
 }

code/observables/dom-events/dom-events-2.js

@@ -1,9 +1,3 @@
-const { Observable } = require('rxjs');
-
-const incrementBtn = document.getElementById('increment');
-const decrementBtn = document.getElementById('decrement');
-const counterEl = document.getElementById('counter');
-
 const source = Observable.merge(
   Observable.fromEvent(incrementBtn, 'click').mapTo(1),
   Observable.fromEvent(decrementBtn, 'click').mapTo(-1),

code/observables/error-handling/error-handling-1.js

@@ -1,26 +1,3 @@
-// // Observable.fromPromise(Promise.reject('lol')).subscribe(x => console.log(x))
-// const source = Observable.create((subscriber) => {
-//   fetchOrdersFromDb((err, orders) => {
-//     if (err) {
-//       try {
-//         subscriber.error(err);
-//         console.log('after');
-//       } catch (e) {
-//         console.log('it threw', e);
-//       }
-//     } else {
-//       subscriber.next(orders);
-//       subscriber.complete();
-//     }
-//   });
-// });
-
-// // source.subscribe(x => console.log(x));
-// source.subscribe({
-//   next: x => console.log(x),
-//   error: e => console.error(e),
-// });
-
 const source = Observable.create((subscriber) => {
   subscriber.next(1);
   subscriber.error(new Error('Uh oh'));

code/observables/error-handling/error-handling-3.js

@@ -1,14 +1,3 @@
-// const source = Observable.create((subscriber) => {
-//   fetchOrdersFromDb((err, orders) => {
-//     if (err) {
-//       subscriber.error(err);
-//     } else {
-//       subscriber.next(orders);
-//       subscriber.complete();
-//     }
-//   });
-// });
-
 fetchOrders()
   .catch((e) => {
     logError(e);

code/observables/error-handling/error-handling-4.js

@@ -1,18 +1,5 @@
-function fetchOrders() {
-  return Observable.create((subscriber) => {
-    fetchOrdersFromDb((err, orders) => {
-      if (err) {
-        subscriber.error(err);
-      } else {
-        subscriber.next(orders);
-        subscriber.complete();
-      }
-    });
-  });
-}
-
 fetchOrders()
-  .retry(3)
+  .retry(2)
   .subscribe({
     next: x => console.log(x),
     error: e => console.error(e),

code/observables/error-handling/error-handling-5.js

@@ -1,29 +1,3 @@
-function fetchOrders() {
-  return Observable.create((subscriber) => {
-    fetchOrdersFromDb((err, orders) => {
-      if (err) {
-        subscriber.error(err);
-      } else {
-        subscriber.next(orders);
-        subscriber.complete();
-      }
-    });
-  });
-}
-
-function legacyFetchOrders() {
-  return Observable.create((subscriber) => {
-    fetchOrdersFromDb((err, orders) => {
-      if (err) {
-        subscriber.error(new Error('nope'));
-      } else {
-        subscriber.next(orders);
-        subscriber.complete();
-      }
-    });
-  });
-}
-
 fetchOrders()
   .catch((e) => {
     logError(e);

code/observables/higher-order/promise-parallel-1.js

@@ -1,18 +1,3 @@
-function fetchOrder(id) {
-  console.log('making promise request for order with id', id);
-
-  return new Promise((resolve) => {
-    const time = Math.random() * 2000;
-
-    setTimeout(() => {
-      resolve({
-        id,
-        name: `Order ${id}`,
-      });
-    }, time);
-  });
-}
-
 const promise = Promise.all([
   fetchOrder(1),
   fetchOrder(2),

code/observables/higher-order/rate-limiting-1.js

@@ -1,23 +1,3 @@
-Object.defineProperty(Observable.ajax, 'get', {
-  value(url) {
-    return Observable.create((observer) => {
-      axios.get(`http://localhost:3000${url}`)
-        .then(({ data }) => {
-          observer.next({ response: data });
-          observer.complete();
-        });
-    });
-
-    // const id = url.replace(/^.*\/(\d+)\/?$/, '$1');
-    // return Observable.of({
-    //   response: {
-    //     id,
-    //     name: `Order ${id}`,
-    //   },
-    // });
-  },
-});
-
 Observable.of(1, 2, 3)
   .concatMap((id) => {
     const url = `/orders/${id}`;

code/observables/hot-vs-cold/hot-1.js

@@ -1,25 +1,3 @@
-class WebSocket {
-  constructor() {
-    this.listeners = [];
-
-    Observable.range(1, 5)
-      .concatMap(n => Observable.of(n).delay(Math.random() * 1000))
-      .subscribe(x => this.emit(x));
-  }
-
-  emit(data) {
-    const event = { data };
-
-    this.listeners.forEach((listener) => {
-      listener(event);
-    });
-  }
-
-  addEventListener(_, listener) {
-    this.listeners.push(listener);
-  }
-}
-
 const socket = new WebSocket('ws://example.com');
 
 const stream = Observable.create((subscriber) => {