import { Stream, Source, Sink, Disposable, Scheduler } from '@tempest/core';
export interface DebugSubscriber<T> {
    next?: (x: T) => any;
    error?: (e: Error) => any;
    complete?: (x?: T) => any;
    dispose?: () => any;
}
export declare function debug<T>(infoOrSpy: string | DebugSubscriber<T>, stream: Stream<T>): Stream<T>;
export declare class Debug<T> implements Source<T> {
    private infoOrSpy;
    private source;
    constructor(infoOrSpy: string | DebugSubscriber<T>, source: Source<T>);
    run(sink: Sink<T>, scheduler: Scheduler): Disposable<T>;
}