import { AnyEvent, Dispose } from "./_interfaces";
import { EventStream } from "./EventStream";
import { Observable } from "./Observable";
export interface PushOp {
    <T>(bus: Bus<T>, event: T | AnyEvent<T>): void;
    <T>(bus: Bus<T>): (event: T | AnyEvent<T>) => void;
}
export interface PushNextOp {
    <T>(bus: Bus<T>, val: T): void;
    <T>(bus: Bus<T>): (val: T) => void;
}
export interface PushErrorOp {
    (bus: Bus<any>, err: Error): void;
    (bus: Bus<any>): (err: Error) => void;
}
export interface PlugOp {
    <T>(bus: Bus<T>, obs: Observable<T>): Dispose;
    <T>(bus: Bus<T>): (bs: Observable<T>) => Dispose;
}
export declare const push: PushOp;
export declare const pushNext: PushNextOp;
export declare const pushError: PushErrorOp;
export declare const pushEnd: typeof _pushEnd;
export declare const plug: PlugOp;
/**
 * Creates a new `Bus` instance.
 *
 * @public
 */
export declare function bus<ValueType>(): Bus<ValueType>;
declare function _pushEnd(bus: Bus<any>): void;
export declare class Bus<T> extends EventStream<T> {
    constructor();
}
export {};