Тестирование наблюдаемого отображения с использованием шариков

У меня есть метод, который принимает наблюдаемое в качестве входных данных и переключается на новое наблюдаемое. В качестве альтернативы я мог бы использовать карту вместо switchMap. Как это можно проверить с помощью шариков?

mapFirstToStr(ob: Observable<boolean>): Observable<string> {
   return ob.pipe(
       first(),
       switchMap(val => of(val ? 'A' : 'B'))
   );
}

Это не работает:

const source = cold('a', { a: true });
const expected = cold('b', { b: 'B' });
expect(mapFirstToStr(source)).toBeObservable(expected);

Я получаю следующую ошибку:

Expected value to equal: [{"frame": 0, "notification": {"error": undefined, "hasValue": true, > "kind": "N", "value": "B"}}]

Received: [{"frame": 0, "notification": {"error": undefined, "hasValue": true, > "kind": "N", "value": "B"}}, {"frame": 0, "notification": {"error": > undefined, "hasValue": false, "kind": "C", "value": undefined}}]

Зод: сила проверки и преобразования данных
Зод: сила проверки и преобразования данных
Сегодня я хочу познакомить вас с библиотекой Zod и раскрыть некоторые ее особенности, например, возможности валидации и трансформации данных, а также...
Как заставить Remix работать с Mantine и Cloudflare Pages/Workers
Как заставить Remix работать с Mantine и Cloudflare Pages/Workers
Мне нравится библиотека Mantine Component , но заставить ее работать без проблем с Remix бывает непросто.
Угловой продивер
Угловой продивер
Оригинал этой статьи на турецком языке. ChatGPT используется только для перевода на английский язык.
TypeScript против JavaScript
TypeScript против JavaScript
TypeScript vs JavaScript - в чем различия и какой из них выбрать?
Синхронизация localStorage в масштабах всего приложения с помощью пользовательского реактивного хука useLocalStorage
Синхронизация localStorage в масштабах всего приложения с помощью пользовательского реактивного хука useLocalStorage
Не все нужно хранить на стороне сервера. Иногда все, что вам нужно, это постоянное хранилище на стороне клиента для хранения уникальных для клиента...
Что такое ленивая загрузка в Angular и как ее применять
Что такое ленивая загрузка в Angular и как ее применять
Ленивая загрузка - это техника, используемая в Angular для повышения производительности приложения путем загрузки модулей только тогда, когда они...
0
0
191
1

Ответы 1

На основе официальные документы для оператора first:

If called with no arguments, first emits the first value of the source Observable, then completes.

Итак, когда ваш наблюдаемый ob излучает первое значение, поток немедленно завершается. Из распечатанного здесь журнала ошибок видно, что полученный массив содержит два объекта. Они оба генерируются в одном кадре (0), а второй имеет значение notification.kind, равное C, что означает, что это событие Complete.

Итак, вы должны были ожидать таких шариков: '(b|)'.

Меня беспокоит то, что выходные значения не совпадают. Основываясь на двух созданных вами наблюдаемых cold, вы испускаете true в наблюдаемой source. Когда вы звоните в mapFirstToStr(source), он проходит через оператора first, а затем через switchMap. Стрелочная функция в switchMap возвращает наблюдаемое со значением, основанным на условии в тернарном операторе. Поскольку полученное значение - true, тройное условие val ? 'A' : 'B' возвращает 'A'. Таким образом, значение в наблюдаемом expected может быть не 'B' (значение из журналов ошибок), а 'A'.

Итак, либо вы испускаете первое значение false:

const source = cold('a', { a: false });
const expected = cold('(b|)', { b: 'B' });
expect(mapFirstToStr(source)).toBeObservable(expected);

Или вы ожидаете 'A':

const source = cold('a', { a: true });
const expected = cold('(b|)', { b: 'A' });
expect(mapFirstToStr(source)).toBeObservable(expected);

Другие вопросы по теме