import { Source, Subscriber, Subscription } from "./_core";
import { AnyEvent } from "./_interfaces";
import { Transaction } from "./_tx";
import { Observable } from "./Observable";
export declare function mutable<T>(o: Observable<T>): MutableSource<T>;
export declare class MutableSource<T> implements Source<T>, Subscription {
    readonly weight: number;
    protected s: Subscriber<T>;
    protected active: boolean;
    protected ended: boolean;
    subscribe(subscriber: Subscriber<T>, order: number): Subscription;
    activate(initialNeeded: boolean): void;
    dispose(): void;
    reorder(order: number): void;
    sendOk(): boolean;
    send(event: T | AnyEvent<T>): void;
    sendNext(val: T): void;
    sendError(err: Error): void;
    sendEnd(): void;
    _next(tx: Transaction, val: T): void;
    _error(tx: Transaction, err: Error): void;
    _end(tx: Transaction): void;
}