Кастомный оператор indicate

Задача

Реализуйте кастомный оператор indicate.

Требования:

• при подписке на поток оператор устанавливает true в переданный Subject;
• после завершения потока (успешно или с ошибкой) оператор устанавливает false в тот же Subject.

const loadingState$ = new Subject<boolean>();
 
const data$ = timer(1000).pipe(
    switchMap(() => of({ name: 'Purecat' })),
    indicate(this.loadingState$),
);
 
data$.subscribe();

Решение

Оптимальное решение (defer + finalize)

import { Observable, Subject, defer } from 'rxjs';
import { finalize } from 'rxjs/operators';
 
/**
 * @param subject$ - Subject для управления состоянием загрузки
 */
function indicate<T>(subject$: Subject<boolean>) {
    // Возвращаем функцию, которая принимает исходный поток (source)
    return (source: Observable<T>): Observable<T> =>
        // defer выполняет subject$.next(true) ровно в момент подписки
        defer(() => {
            subject$.next(true);
 
            // finalize сработает при complete или error
            return source.pipe(finalize(() => subject$.next(false)));
        });
}

defer гарантирует, что next(true) выполнится на каждую подписку (а не один раз при создании оператора), а finalize — общий выход для успешного завершения, ошибки и отписки.