fix(Effects): Provide instance from actions to ofType lettable operat…

…or (#751)

Closes #739

modules/effects/spec/actions.spec.ts

@@ -10,7 +10,9 @@ import {
   ActionsSubject,
 } from '@ngrx/store';
 import { Actions, ofType } from '../';
-import { map, toArray } from 'rxjs/operators';
+import { map, toArray, switchMap } from 'rxjs/operators';
+import { hot, cold } from 'jasmine-marbles';
+import { of } from 'rxjs/observable/of';
 
 describe('Actions', function() {
   let actions$: Actions;
@@ -75,4 +77,17 @@ describe('Actions', function() {
     actions.forEach(action => dispatcher.next({ type: action }));
     dispatcher.complete();
   });
+
+  it('should support using the ofType instance operator', () => {
+    const action = { type: ADD };
+
+    const response = cold('-b', { b: true });
+    const expected = cold('--c', { c: true });
+
+    const effect$ = new Actions(hot('-a', { a: action }))
+      .ofType(ADD)
+      .pipe(switchMap(() => response));
+
+    expect(effect$).toBeObservable(expected);
+  });
 });

modules/effects/src/actions.ts

@@ -23,7 +23,7 @@ export class Actions<V = Action> extends Observable<V> {
   }
 
   ofType<V2 extends V = V>(...allowedTypes: string[]): Actions<V2> {
-    return ofType<any>(...allowedTypes)(this.source as Actions<V2>);
+    return ofType<any>(...allowedTypes)(this as Actions<any>);
   }
 }