import { IScheduler } from '../schedulers/Scheduler';
import { IObservable } from './Observable';
import { IObserver } from './Observer';
import { ISubscriberFunction } from './SubscriberFunction';
import { CompositeSubscription, ISubscription } from './Subscription';
export interface IObservable<T> {
    subscribe(observer: IObserver<T>, scheduler: IScheduler): ISubscription;
}
export declare class Observable<T> implements IObservable<T> {
    private f;
    constructor(f: ISubscriberFunction<T>);
    run(cSub: CompositeSubscription, observer: IObserver<T>, scheduler: IScheduler): void;
    subscribe(observer: IObserver<T>, scheduler: IScheduler): ISubscription;
}