Added support for Observe param of request options

Author: mikhail

index.ts

@@ -1,13 +1,14 @@
 export * from './src/ngx-http-rest.module';
 import { Response } from '@angular/http';
-import { HttpRestUtils, path, body, query, headers, produces } from "ngx-http-rest/src/ngx-http-rest.utils";
+import { HttpRestUtils, path, body, query, headers, produces, observe } from "ngx-http-rest/src/ngx-http-rest.utils";
 
 export let Path = path;
 export let PathParam = path;
 export let Body = body(null);
 export let Query = query(null);
 export let QueryParam = query;
 export let QueryParams = query(null);
+export let Observe = observe;
 
 // Headers
 export let Headers = headers;

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ngx-http-rest",
-  "version": "0.3.2",
+  "version": "0.4.0",
   "devDependencies": {
     "@angular/http": "^4.0.0",
     "@angular/core": "^4.0.0",

src/ngx-http-rest.utils.ts

@@ -1,16 +1,22 @@
 import { Injectable } from '@angular/core';
 import { Observable } from 'rxjs';
 import { HttpClient, HttpParams, HttpHeaders } from "@angular/common/http";
+import { HttpObserve } from "@angular/common/http/src/client";
 
 interface httpRequestOptions {
   body?: any;
   headers?: HttpHeaders;
   params?: HttpParams;
+  observe?: HttpObserve;
   reportProgress?: boolean;
   responseType?: 'arraybuffer' | 'blob' | 'json' | 'text';
   withCredentials?: boolean;
 }
 
+
+export function observe(annotations: any) {
+  return (...args: any[]) => HttpRestUtils.decorate.apply(this, ['observe', annotations, ...args]);
+}
 export function path(annotations: any) {
   return (...args: any[]) => HttpRestUtils.decorate.apply(this, ['path', annotations, ...args]);
 }
@@ -103,17 +109,27 @@ export class HttpRestUtils {
         const search = HttpRestUtils.collectQueryParams(target, key, args);
         const headers = HttpRestUtils.collectHeaders(target, key, args);
         const producesType = HttpRestUtils.produce(target, key, args);
+        const observe = HttpRestUtils.getObserve(target, key, args)
         const params: httpRequestOptions = {
           body,
           params: search,
           headers,
-          responseType: producesType
+          responseType: producesType,
+          observe
         };
         return HttpRestUtils.http.request(requestMethodName, url, params);
       };
     };
   }
 
+  private static getObserve(target: any, methodName: string, args: any[]) {
+    if (target[RESOURSE_METADATA_ROOT].methods
+      && target[RESOURSE_METADATA_ROOT].methods[methodName]) {
+       return target[RESOURSE_METADATA_ROOT].methods[methodName].observe;
+     }
+     return undefined;
+  }
+
   private static produce(target: any, methodName: string, args: any[]) {
     if (target[RESOURSE_METADATA_ROOT].methods
      && target[RESOURSE_METADATA_ROOT].methods[methodName]) {