Updating observable on webscoket event
Change-Id: I8325785b8d40b646ea67f28b61b8d603803a571e
diff --git a/src/app/services/rest/core.service.ts b/src/app/services/rest/core.service.ts
index 04097a6..3890c47 100644
--- a/src/app/services/rest/core.service.ts
+++ b/src/app/services/rest/core.service.ts
@@ -2,9 +2,10 @@
// Imports
import {AppConfig} from '../../config/app.config';
-import { Injectable } from '@angular/core';
-import { Http, Response, Headers, RequestOptions } from '@angular/http';
+import {Injectable} from '@angular/core';
+import {Response} from '@angular/http';
import {Observable} from 'rxjs/Rx';
+import {XosHttp} from './xoshttp.service';
// Import RxJs required methods
import 'rxjs/add/operator/map';
@@ -12,19 +13,22 @@
@Injectable()
export class CoreService {
- // Resolve HTTP using the constructor
- constructor (private http: Http) {}
// private instance variable to hold base url
private baseUrl = AppConfig.apiEndpoint;
+ // Resolve HTTP using the constructor
+ constructor (private http: XosHttp) {}
+
// Fetch all existing comments
getCoreEndpoints() : Observable<any[]> {
+ const search = 'some=param';
+
// ...using get request
- return this.http.get(`${this.baseUrl}/core/`)
+ return this.http.get(`${this.baseUrl}/core/`, {search})
// ...and calling .json() on the response to return data
- .map((res:Response) => res.json())
- //...errors if any
+ .map((res: Response) => res.json())
+ // ...errors if any
.catch((error:any) => Observable.throw(error.json().error || 'Server error'));
}