refactor(examples): use http

Author: PatrickJS

examples/src/index.ts

@@ -73,7 +73,7 @@ function smokeTest() {
       var body = Buffer.concat(bodyChunks);
       // console.log('GOOD' /*, body.toString()*/ );
       // ...and/or process the entire body here.
-    })
+    });
   });
 
   req.on('error', function(e) {

examples/src/universal/test_page/app.ts

@@ -108,17 +108,17 @@ export class App {
   buttonTest: string   = '';
   testingInput: string = 'default state on component';
 
-  // todosObs1$ = this.http.get(App.queries.todos)
-  //   .filter(res => res.status >= 200 && res.status < 300)
-  //   .map(res => res.json())
-  //   .map(data => transformData(data)); // ensure correct data prop types
+  todosObs1$ = this.http.get(App.queries.todos)
+    .filter(res => res.status >= 200 && res.status < 300)
+    .map(res => res.json())
+    .map(data => transformData(data)); // ensure correct data prop types
   todosObs2$ = this.http.get(App.queries.todos)
     .filter(res => res.status >= 200 && res.status < 300)
     .map(res => res.json())
     .map(data => transformData(data)); // ensure correct data prop types
-  // todosObs3$ = this.http.get(App.queries.todos)
-  //   .map(res => res.json())
-  //   .map(data => transformData(data));
+  todosObs3$ = this.http.get(App.queries.todos)
+    .map(res => res.json())
+    .map(data => transformData(data));
 
   constructor(private http: Http) {
 
@@ -129,21 +129,21 @@ export class App {
     // this.addItem();
     // this.addItem();
 
-    // this.todosObs1$.subscribe(
-    //   // onValue
-    //   todos => {
-    //     todos.map(todo => this.addItem(todo));
-    //     this.anotherAjaxCall();
-    //   },
-    //   // onError
-    //   err => {
-    //     console.error('err', err);
-    //     throw err;
-    //   },
-    //   // onComplete
-    //   () => {
-    //     console.log('complete request1');
-    //   });
+    this.todosObs1$.subscribe(
+      // onValue
+      todos => {
+        todos.map(todo => this.addItem(todo));
+        this.anotherAjaxCall();
+      },
+      // onError
+      err => {
+        console.error('err', err);
+        throw err;
+      },
+      // onComplete
+      () => {
+        console.log('complete request1');
+      });
 
     this.todosObs2$.subscribe(
       // onValue
@@ -164,16 +164,16 @@ export class App {
 
   }
   anotherAjaxCall() {
-    // this.todosObs3$.subscribe(
-    //   todos => {
-    //     console.log('anotherAjaxCall data 3', todos);
-    //   },
-    //   err => {
-    //     console.log('anotherAjaxCall err')
-    //   },
-    //   () => {
-    //     console.log('anotherAjaxCall complete ajax')
-    //   });
+    this.todosObs3$.subscribe(
+      todos => {
+        console.log('anotherAjaxCall data 3', todos);
+      },
+      err => {
+        console.log('anotherAjaxCall err');
+      },
+      () => {
+        console.log('anotherAjaxCall complete ajax');
+      });
   }
 
   log(value) {
@@ -212,5 +212,3 @@ export class App {
   }
 
 }
-
-

examples/src/universal/test_page/browser.ts

@@ -5,6 +5,7 @@ console.timeEnd('angular2/core in client');
 import {BROWSER_PROVIDERS, BROWSER_APP_PROVIDERS} from 'angular2/platform/browser';
 import {Http, HTTP_PROVIDERS} from 'angular2/http';
 
+import 'rxjs/Rx';
 // import {
 //   NG_PRELOAD_CACHE_PROVIDERS,
 //   PRIME_CACHE