diff --git a/packages/schematics/src/collection/ngrx/files/__directory__/__fileName__.effects.spec.ts__tmpl__ b/packages/schematics/src/collection/ngrx/files/__directory__/__fileName__.effects.spec.ts__tmpl__
index f317bc30d56dc..87b67246adfd5 100644
--- a/packages/schematics/src/collection/ngrx/files/__directory__/__fileName__.effects.spec.ts__tmpl__
+++ b/packages/schematics/src/collection/ngrx/files/__directory__/__fileName__.effects.spec.ts__tmpl__
@@ -2,7 +2,7 @@ import {TestBed, async} from '@angular/core/testing';
 import {StoreModule} from '@ngrx/store';
 import {provideMockActions} from '@ngrx/effects/testing';
 import {DataPersistence} from '@nrwl/nx';
-import {readAll, hot} from '@nrwl/nx/testing';
+import {hot} from '@nrwl/nx/testing';
 import {<%= className %>Effects} from './<%= fileName %>.effects';
 
 describe('<%= className %>Effects', () => {
@@ -25,11 +25,11 @@ describe('<%= className %>Effects', () => {
   });
 
   describe('someEffect', () => {
-    it('should work', async(async () => {
+    it('should work', () => {
       actions = hot('-a-|', {a: {type: 'LOAD_DATA'}});
-      expect(await readAll(effects.loadData)).toEqual([
-        {type: 'DATA_LOADED', payload: {}}
-      ]);
-    }));
+      expect(effects.loadData).toBeObservable(
+        hot('-a-|', {a: {type: 'DATA_LOADED', payload: {}}})
+      );
+    });
   });
 });