123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- import { IScheduler } from '../Scheduler';
- import { Operator } from '../Operator';
- import { PartialObserver } from '../Observer';
- import { Subscriber } from '../Subscriber';
- import { Notification } from '../Notification';
- import { TeardownLogic } from '../Subscription';
- import { Action } from '../scheduler/Action';
- import { MonoTypeOperatorFunction } from '../interfaces';
- export declare function observeOn<T>(scheduler: IScheduler, delay?: number): MonoTypeOperatorFunction<T>;
- export declare class ObserveOnOperator<T> implements Operator<T, T> {
- private scheduler;
- private delay;
- constructor(scheduler: IScheduler, delay?: number);
- call(subscriber: Subscriber<T>, source: any): TeardownLogic;
- }
- export declare class ObserveOnSubscriber<T> extends Subscriber<T> {
- private scheduler;
- private delay;
- static dispatch(this: Action<ObserveOnMessage>, arg: ObserveOnMessage): void;
- constructor(destination: Subscriber<T>, scheduler: IScheduler, delay?: number);
- private scheduleMessage(notification);
- protected _next(value: T): void;
- protected _error(err: any): void;
- protected _complete(): void;
- }
- export declare class ObserveOnMessage {
- notification: Notification<any>;
- destination: PartialObserver<any>;
- constructor(notification: Notification<any>, destination: PartialObserver<any>);
- }
|