import { Observable } from 'rxjs'; /** * This helper can be used to control the completion of another observable. * * Example: * ``` * private stopper = new ObservableStopper(); * * ngOnInit(): void { * this.myObservable$.pipe( * ..., * takeUntil(this.stopper.stopper$), * ).subscribe((value) => { * ... * }) * } * * ngOnDestroy(): void { * this.stopper.stop(); * } * ``` */ export declare class ObservableStopper { private stopperSubj$; private pubStopper$; /** * The multicast observable that will emit and complete when `stop()` is called. */ get stopper$(): Observable; constructor(); /** * @returns `true` if this `ObservableStopper` has been stopped, otherwise `false. */ get isStopped(): boolean; /** * Instructs all observables depending on this `ObservableStopper` to complete. */ stop(): void; }