watch.ts

export function watch<T>(
    changeDetectorRef: ChangeDetectorRef,
): MonoTypeOperatorFunction<T> {
    return (source: Observable<T>) =>
        source.pipe(
            tap(() => {
                changeDetectorRef.markForCheck();
            }),
        );
}