import { Consumer } from './types';
export declare function subscribe<T>(onData: (t: T) => void, onEnd?: (e?: any) => void, onDispose?: () => void): Consumer<T>;