Я пытаюсь выполнить модульный тест, в котором эффект использует сервис для извлечения результатов из API, а затем запускает либо действие успеха, либо действие ошибки.Я продолжаю получать ошибку TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.
.Не совсем уверен, что нужно изменить, чтобы это работало.
Включая тест проверки ошибок и соответствующий код.
Угловой
Angular CLI: 7.1.4
Node: 10.5.0
OS: win32 x64
Angular: 7.1.4
... animations, cli, common, compiler, compiler-cli, core, forms
... http, language-service, platform-browser
... platform-browser-dynamic, router
Package Version
-----------------------------------------------------------
@angular-devkit/architect 0.10.7
@angular-devkit/build-angular 0.10.7
@angular-devkit/build-optimizer 0.10.7
@angular-devkit/build-webpack 0.10.7
@angular-devkit/core 7.0.7
@angular-devkit/schematics 7.1.4
@angular/cdk 7.2.0
@angular/material 7.2.0
@ngtools/webpack 7.0.7
@schematics/angular 7.1.4
@schematics/update 0.11.4
rxjs 6.3.3
typescript 3.1.6
webpack 4.19.1
Тест
describe('ResultsEffects', () => {
let store: jasmine.SpyObj<Store<FeatureState>>;
let ebs: jasmine.SpyObj<EBSService>;
let snackbar: jasmine.SpyObj<SnackBarService>;
beforeEach(() => {
store = jasmine.createSpyObj('store', ['pipe']);
ebs = jasmine.createSpyObj('EBSService', ['getPollResults', 'getUserHasVoted', 'getSettings']);
snackbar = jasmine.createSpyObj('SnackBarService', ['notify']);
});
describe('fetchResults', () => {
it(`should dispatch 'FetchPanelResultsError'`, () => {
const fetchAction = new FetchPanelResults();
const error = { statusText: 'ERROR' };
const errorAction = new FetchPanelResultsError({ error: error.statusText });
const values = {
a: fetchAction,
e: errorAction
};
const source = cold('a', values);
const expected = cold('--e', values);
const actions = new Actions(source);
ebs.getPollResults.and.returnValue(throwError(error));
const effects = new ResultsEffects(
actions,
store,
snackbar,
ebs
);
expect(
effects.fetchResults$({
debounce: 20,
scheduler: getTestScheduler()
})
).toBeObservable(expected);
});
});
});
Эффект
@Effect()
fetchResults$ = ({ debounce = 500, scheduler = asyncScheduler } = {}) => this.actions$.pipe(
ofType<SetPanelResults>(PanelResultsActionTypes.FETCH_PANEL_RESULTS),
// need alternate method for this
// withLatestFrom(this.featureState$),
// map(([_, state]) => state.twitch.token),
debounceTime(debounce, scheduler),
switchMap((token) =>
this.ebs.getPollResults(token).pipe(
map(res => new SetPanelResults(res.data.results)),
catchError(error => of(new FetchPanelResultsError({ error: error.statusText })))
)
)
)
Сервис
getPollResults(token: string): Observable<PollResultsFetchData> {
const options = {
headers: ebsHeaders(token)
};
return this.http.get<PollResultsFetchData>(`${this.ebsURL}/poll/results`, options);
}
Обновление: добавлен отладчик, чтобы вызвать ошибку с шариками.Еще нужна альтернатива withLatestFrom
.