import { Source, Subscriber, Subscription } from "../_core";
import { AnyEvent } from "../_interfaces";
import { Task } from "../scheduler/index";
export declare abstract class Root<T> implements Source<T> {
    readonly sync: boolean;
    readonly weight: number;
    constructor(sync: boolean);
    subscribe(subscriber: Subscriber<T>, order: number): Subscription;
    protected abstract create(subscriber: Subscriber<T>): Activation<T, any>;
}
export declare abstract class Activation<T, R extends Root<T>> implements Task, Subscription {
    protected readonly owner: R;
    protected active: boolean;
    protected subscriber: Subscriber<T>;
    constructor(owner: R, subscriber: Subscriber<T>);
    run(): void;
    activate(initialNeeded: boolean): void;
    dispose(): void;
    reorder(order: number): void;
    send(event: T | AnyEvent<T>): void;
    protected abstract start(): void;
    protected abstract stop(): void;
    protected sendNext(val: T): void;
    protected sendError(err: Error): void;
    protected sendEnd(): void;
}