И
Size: a a a
И
S
switchMap((item) => new Observable((observer) {
observer.next(item);
return source.subscribe({
error: (e) => observer.error(e),
complete: () => observer.complete();
});
}));
Вキ
S
Вキ
S
Вキ
Вキ
S
S
Вキ
m
Вキ
m
Вキ
m
S
IB
const toEmpty = () = filter(() => false);
switchMap((item) => merge(
of(item),
source.pipe(toEmpty())
))