it('should emit ActionStockMarketRetrieveError on error', () => {
      const retrieveAction = new ActionStockMarketRetrieve({
        symbol
      });
      const error = 'ERROR';
      const errorAction = new ActionStockMarketRetrieveError({
        error
      } as any);
      const values = {
        a: retrieveAction,
        e: errorAction
      };
      const source = cold('a', values);
      const expected = cold('--e', values);
      const actions = new Actions(source);

      stockMarket.retrieveStock.and.returnValue(throwError(error));

      const effects = new StockMarketEffects(
        actions,
        localStorage,
        stockMarket
      );

      expect(
        effects.retrieveStock({
          debounce: 20,
          scheduler: getTestScheduler()
        })
      ).toBeObservable(expected);
    });

  beforeEach(() => {
    fixture = TestBed.configureTestingModule({
      imports: [TranslateModule.forRoot()],
      declarations: [RtlSupportDirective, TestComponent],
      providers: [
        {
          provide: TranslateService,
          useValue: {
            currentLang: 'he',
            onLangChange: cold('--x--y|', {
              x: { lang: 'he' },
              y: { lang: 'de' }
            })
          }
        }
      ]
    }).createComponent(TestComponent);

    getTestScheduler().flush(); // flush the observables
    fixture.detectChanges(); // initial binding

    // all elements with an attached RtlDirective
    des = fixture.debugElement.queryAll(By.directive(RtlSupportDirective));

    // the h2 without the RtlDirective
    bareH2 = fixture.debugElement.query(By.css('h2:not([rtl])'));
  });

  it('should set "direction" rule value to "ltr" after current language changed to NOT hebrew', () => {
    getTestScheduler().flush(); // flush the observables
    fixture.detectChanges();

    const textAlign = des[0].nativeElement.style.textAlign;
    expect(textAlign).toBe('left');
    const direction = des[0].nativeElement.style.direction;
    expect(direction).toBe('ltr');
  });

    beforeEach(() => {
      const originalDelay = Observable.prototype.delay;
      const scheduler = getTestScheduler();
      spyOn(Observable.prototype, 'delay').and.callFake(function(time) {
        return originalDelay.call(this, time, scheduler);
      });
      TestBed.configureTestingModule(makeTestbedConfig(state));

      effects = TestBed.get(ReportEffects);
      service = TestBed.get(ApiService);
    });

    it(`should not do anything if the query is an empty string`, () => {
      const action = new FindBookPageActions.SearchBooks('');

      actions$ = hot('-a---', { a: action });
      const expected = cold('---');

      expect(
        effects.search$({
          debounce: 30,
          scheduler: getTestScheduler(),
        })
      ).toBeObservable(expected);
    });

  it('should display error when TwainService fails', fakeAsync(() => {
    // observable error after delay
    const q$ = cold('---#|', null, new Error('TwainService test failure'));
    getQuoteSpy.and.returnValue( q$ );

    fixture.detectChanges(); // ngOnInit()
    expect(quoteEl.textContent).toBe('...', 'should show placeholder');

    getTestScheduler().flush(); // flush the observables
    tick();                     // component shows error after a setTimeout()
    fixture.detectChanges();    // update error message

    expect(errorMessage()).toMatch(/test failure/, 'should display error');
    expect(quoteEl.textContent).toBe('...', 'should show placeholder');
  }));