Merge pull request #2354 from herflis/my-fix-branch

feat(AjaxObservable) : support 'PATCH' request type
ReactiveX · Feb 14, 2017 · 9c1f793 · 9c1f793
2 parents 3f01114 + 1821519
commit 9c1f793
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/spec/observables/dom/ajax-spec.ts b/spec/observables/dom/ajax-spec.ts
@@ -853,6 +853,21 @@ describe('Observable.ajax', () => {
     delete root.XMLHttpRequest.prototype.onerror;
     delete root.XMLHttpRequest.prototype.upload;
   });
+
+  describe('ajax.patch', () => {
+    it('should create an AjaxObservable with correct options', () => {
+      const body = { foo: 'bar' };
+      const headers = { first: 'first' };
+      // returns Observable, not AjaxObservable, so needs a cast
+      const { request } = <any>Rx.Observable
+        .ajax.patch('/flibbertyJibbet', body, headers);
+
+      expect(request.method).to.equal('PATCH');
+      expect(request.url).to.equal('/flibbertyJibbet');
+      expect(request.body).to.equal(body);
+      expect(request.headers).to.equal(headers);
+    });
+  });
 });
 
 class MockXMLHttpRequest {

diff --git a/src/observable/dom/AjaxObservable.ts b/src/observable/dom/AjaxObservable.ts
@@ -66,6 +66,7 @@ export interface AjaxCreationMethod {
   get(url: string, headers?: Object): Observable<AjaxResponse>;
   post(url: string, body?: any, headers?: Object): Observable<AjaxResponse>;
   put(url: string, body?: any, headers?: Object): Observable<AjaxResponse>;
+  patch(url: string, body?: any, headers?: Object): Observable<AjaxResponse>;
   delete(url: string, headers?: Object): Observable<AjaxResponse>;
   getJSON<T>(url: string, headers?: Object): Observable<T>;
 }
@@ -86,6 +87,10 @@ export function ajaxPut(url: string, body?: any, headers?: Object): Observable<A
   return new AjaxObservable<AjaxResponse>({ method: 'PUT', url, body, headers });
 };
 
+export function ajaxPatch(url: string, body?: any, headers?: Object): Observable<AjaxResponse> {
+  return new AjaxObservable<AjaxResponse>({ method: 'PATCH', url, body, headers });
+};
+
 export function ajaxGetJSON<T>(url: string, headers?: Object): Observable<T> {
   return new AjaxObservable<AjaxResponse>({ method: 'GET', url, responseType: 'json', headers })
     .lift<T>(new MapOperator<AjaxResponse, T>((x: AjaxResponse, index: number): T => x.response, null));
@@ -132,6 +137,7 @@ export class AjaxObservable<T> extends Observable<T> {
     create.post = ajaxPost;
     create.delete = ajaxDelete;
     create.put = ajaxPut;
+    create.patch = ajaxPatch;
     create.getJSON = ajaxGetJSON;
 
     return <AjaxCreationMethod>create;