import { Observable, Observer, EventHandler, EventDispachter } from "./common"; export type Subject = Observable & Observer; export declare function subject(source?: Observable): Subject; export declare function defer(f: () => Observable): Observable; type AsyncScheduler = (callback: () => void) => void; declare const schedulers: { promise: (callback: () => void) => void; setImmediate: ((callback: () => void) => any) | null; setTimeout: (callback: () => void) => number; }; declare const setAsapScheduler: (schedulerType: keyof typeof schedulers | AsyncScheduler) => void; export { setAsapScheduler }; export declare function of(...data: T[]): Observable; export declare function fromArray(data: ArrayLike): Observable; export declare function interval(period: number): Observable; export declare function timer(delay: number, period?: number): Observable; export declare function fromEventPattern(add: (n: EventHandler) => void, remove: (n: EventHandler) => void): Observable; export declare function fromEvent(target: EventDispachter, name: N): Observable; export declare function fromPromise(promise: Promise): Observable; export declare function fromFetch(input: RequestInfo, init?: RequestInit): Observable; export declare function fromIterable(source: Iterable): Observable; export declare function fromReader(source: ReadableStreamDefaultReader): Observable; export declare function fromReadableStream(source: ReadableStream): Observable; export declare function fromAnimationFrame(): Observable; export declare function range(start: number, count: number): Observable; export declare function bindCallback(call: Function, thisArg: any, ...args: any[]): Observable; export declare function bindNodeCallback(call: Function, thisArg: any, ...args: any[]): Observable; export declare function never(): Observable; export declare function throwError(e: any): Observable; export declare function empty(): Observable; //# sourceMappingURL=producer.d.ts.map