import { Source } from "../_core";
import { In, Out } from "../_interfaces";
import { Transaction } from "../_tx";
import { OnTimeout, Timeout } from "../scheduler/index";
import { InitialAndChanges } from "./_changes";
export declare const throttle: CurriedThrottle;
export interface CurriedThrottle {
    <ObsType, ValueType>(delay: number, observable: In<ObsType, ValueType>): Out<ObsType, ValueType>;
    (delay: number): <ObsType, ValueType>(observable: In<ObsType, ValueType>) => Out<ObsType, ValueType>;
}
export declare const bufferingThrottle: CurriedBufferingThrottle;
export interface CurriedBufferingThrottle {
    <ObsType, ValueType>(minimumInterval: number, observable: In<ObsType, ValueType>): Out<ObsType, ValueType>;
    (minimumInterval: number): <ObsType, ValueType>(observable: In<ObsType, ValueType>) => Out<ObsType, ValueType>;
}
export declare abstract class ThrottleBase<T> extends InitialAndChanges<T> implements OnTimeout {
    protected delay: number;
    protected to: Timeout | null;
    constructor(source: Source<T>, delay: number);
    dispose(): void;
    nextInitial(tx: Transaction, val: T): void;
    abstract nextChange(tx: Transaction, val: T): void;
    abstract due(): void;
    protected resetTimeout(): void;
    protected ensureTimeout(): void;
}
export declare class Throttle<T> extends ThrottleBase<T> {
    protected memo: T;
    protected ended: boolean;
    dispose(): void;
    nextChange(tx: Transaction, val: T): void;
    end(tx: Transaction): void;
    due(): void;
}