The way how we can handle Observables is really similar to other scenarios we have already covered, check the following code:
it('Async test example - RxJS Observables',fakeAsync(() => {let test:boolean;console.log('Creating observable');consttest$=of(test); test$.pipe(delay(1000) ).subscribe(() => { test =true; });tick(1000);expect(test).toBeTruthy();}));
whenStable()
Get a promise that resolves when the fixture is stable. This can be used to resume testing after events have triggered asynchronous activity or asynchronous change detection.