import { Source, Scheduler } from './interfaces';
export declare function withDefaultScheduler<T>(f: (x: T) => any, source: Source<T>): Promise<T>;
export declare function withScheduler<T>(f: (x: T) => any, source: Source<T>, scheduler: Scheduler): Promise<T>;
export declare function runSource<T>(f: (x: T) => any, source: Source<T>, scheduler: Scheduler, end: (x?: T) => any, error: (e: Error) => any): void;