Use RxJS 5.5 lettable operators

Author: mpalourdio

CHANGELOG.MD

@@ -8,6 +8,8 @@ See [customization](https://github.com/mpalourdio/ng-http-loader#customizing-the
 
 The library footprint has been reduced by minifying templates and stylesheets before inlining them.
 
+The library now takes advantage of [RxJS lettable operators](https://github.com/ReactiveX/rxjs/blob/master/doc/lettable-operators.md)
+
 ## v0.5.1
 
 This release fixes a bug that could cause the spinner to not show if an http request were performed **before** the spinner component was initialized.  

src/components/spinner/spinner.component.ts

@@ -13,7 +13,7 @@ import { Spinkit } from '../../spinkits';
 import { PendingInterceptorService } from '../../services/pending-interceptor.service';
 import { timer } from 'rxjs/observable/timer';
 import { Observable } from 'rxjs/Observable';
-import 'rxjs/add/operator/debounce';
+import { debounce } from 'rxjs/operators';
 
 @Component({
     selector: 'spinner',
@@ -37,7 +37,7 @@ export class SpinnerComponent implements OnDestroy, OnInit {
     constructor(private pendingRequestInterceptorService: PendingInterceptorService) {
         this.subscription = this.pendingRequestInterceptorService
             .pendingRequestsStatus
-            .debounce(this.handleDebounce.bind(this))
+            .pipe(debounce(this.handleDebounce.bind(this)))
             .subscribe(hasPendingRequests => {
                 this.isSpinnerVisible = hasPendingRequests;
             });

src/services/pending-interceptor.service.ts

@@ -11,9 +11,7 @@ import { Injectable } from '@angular/core';
 import { HttpEvent, HttpHandler, HttpInterceptor, HttpRequest } from '@angular/common/http';
 import { Observable } from 'rxjs/Observable';
 import { ReplaySubject } from 'rxjs/ReplaySubject';
-import 'rxjs/add/operator/map';
-import 'rxjs/add/operator/catch';
-import 'rxjs/add/operator/finally';
+import { catchError, finalize, map } from 'rxjs/operators';
 import 'rxjs/add/observable/throw';
 
 @Injectable()
@@ -51,21 +49,23 @@ export class PendingInterceptorService implements HttpInterceptor {
             }
         }
 
-        return next.handle(req).map(event => {
-            return event;
-        })
-            .catch(error => {
+        return next.handle(req).pipe(
+            map(event => {
+                return event;
+            }),
+            catchError(error => {
                 return Observable.throw(error);
-            })
-            .finally(() => {
+            }),
+            finalize(() => {
                 if (!shouldBypass) {
                     this._pendingRequests--;
 
                     if (0 === this._pendingRequests) {
                         this._pendingRequestsStatus.next(false);
                     }
                 }
-            });
+            })
+        );
     }
 }