import { Observable } from "rxjs"; export type HandlerCallbackFn = (arg: T) => void; export type SubHandlerFn = (handler: HandlerCallbackFn) => void; export declare class SubscriptionStreamHandler { #private; readonly stream$: Observable; constructor(subscribeFn: SubHandlerFn, unsubscribeFn: SubHandlerFn); destroy(): void; }