RxJs Course

Your Name · Your Name · commit 2ec1b9275ca3 · 2018-06-19T13:38:32.000+02:00
diff --git a/server/get-courses.route.ts b/server/get-courses.route.ts
@@ -7,27 +7,24 @@ import {COURSES} from "./db-data";
 
 export function getAllCourses(req: Request, res: Response) {
 
-    /*
+
     const error = (Math.random() >= 0.5);
 
     if (error) {
         console.log("ERROR loading courses!");
         res.status(500).json({message: 'random error occurred.'});
     }
     else {
-    */
 
         setTimeout(() => {
 
-            res.status(500).json({message: ' error occurred.'});
-
-            // res.status(200).json({payload:Object.values(COURSES)});
+             res.status(200).json({payload:Object.values(COURSES)});
 
         }, 200);
 
 
 
-   // }
+    }
 }
 
 
diff --git a/src/app/home/home.component.ts b/src/app/home/home.component.ts
@@ -1,7 +1,7 @@
 import {Component, OnInit} from '@angular/core';
 import {Course} from "../model/course";
 import {interval, noop, Observable, of, throwError, timer} from 'rxjs';
-import {catchError, delayWhen, finalize, map, retryWhen, shareReplay, tap} from 'rxjs/operators';
+import {catchError, delay, delayWhen, finalize, map, retryWhen, shareReplay, tap} from 'rxjs/operators';
 import {createHttpObservable} from '../common/util';
 
 
@@ -22,21 +22,14 @@ export class HomeComponent implements OnInit {
 
         const courses$: Observable<Course[]> = http$
             .pipe(
-                catchError(err => {
-
-                    console.log("Error occurred", err);
-
-                    return throwError(err);
-
-                }),
-                finalize(() => {
-
-                    console.log('Finalize executed..');
-
-                }),
                 tap(() => console.log("HTTP request executed")),
                 map(res => Object.values(res["payload"]) ),
-                shareReplay()
+                shareReplay(),
+                retryWhen(errors =>
+                    errors.pipe(
+                    delayWhen(() => timer(2000)
+                    )
+                ) )
             );
 
         this.beginnerCourses$ = courses$
