import { Operation, Transaction } from "./_tx";
import { Task } from "./scheduler/index";
export interface Subscriber<T> {
    next(tx: Transaction, val: T): void;
    error(tx: Transaction, err: Error): void;
    end(tx: Transaction): void;
}
export interface Subscription {
    activate(initialNeeded: boolean): void;
    dispose(): void;
    reorder(order: number): void;
}
export interface Source<T> {
    readonly weight: number;
    subscribe(subscriber: Subscriber<T>, order: number): Subscription;
}
export declare const NONE: any;
export declare const NOOP_SUBSCRIBER: {
    next(tx: Transaction, val: any): void;
    error(tx: Transaction, err: Error): void;
    end(tx: Transaction): void;
};
export declare const NOOP_SUBSCRIPTION: {
    activate(initialNeeded: boolean): void;
    dispose(): void;
    reorder(order: number): void;
};
export declare function setTx(tx: Transaction): void;
export declare function isInTx(): boolean;
export declare function sendNextInTx<T>(subscriber: Subscriber<T>, val: T): void;
export declare function sendEndInTx(subscriber: Subscriber<any>): void;
export declare function sendErrorInTx(subscriber: Subscriber<any>, err: Error): void;
export declare function queueToEndOfTx(op: Operation): void;
export interface InvokeableWithParam<P> {
    invoke(p: P): void;
}
export interface InvokeableWithoutParam {
    invoke(): void;
}
export declare type Invokeable<P> = P extends undefined ? InvokeableWithoutParam : InvokeableWithParam<P>;
export declare function invoke(invokeable: InvokeableWithoutParam): Task;
export declare function invokeWith<T>(invokeable: InvokeableWithParam<T>, param: T): Task;