import { Observable } from '../Observable'; import { Scheduler } from '../Scheduler'; import { Operator } from '../Operator'; import { PartialObserver } from '../Observer'; import { Subscriber } from '../Subscriber'; import { Notification } from '../Notification'; import { TeardownLogic } from '../Subscription'; /** * @see {@link Notification} * * @param scheduler * @param delay * @return {Observable|WebSocketSubject|Observable} * @method observeOn * @owner Observable */ export declare function observeOn(this: Observable, scheduler: Scheduler, delay?: number): Observable; export declare class ObserveOnOperator implements Operator { private scheduler; private delay; constructor(scheduler: Scheduler, delay?: number); call(subscriber: Subscriber, source: any): TeardownLogic; } /** * We need this JSDoc comment for affecting ESDoc. * @ignore * @extends {Ignored} */ export declare class ObserveOnSubscriber extends Subscriber { private scheduler; private delay; static dispatch(arg: ObserveOnMessage): void; constructor(destination: Subscriber, scheduler: Scheduler, delay?: number); private scheduleMessage(notification); protected _next(value: T): void; protected _error(err: any): void; protected _complete(): void; } export declare class ObserveOnMessage { notification: Notification; destination: PartialObserver; constructor(notification: Notification, destination: PartialObserver); }