import { Subscriber, Subscription } from "./_core";
import { Dispatcher } from "./_dispatcher";
import { Subscribe } from "./_interfaces";
import * as Sym from "./_symbols";
import { Transaction } from "./_tx";
import { HKT, Observable } from "./Observable";
export declare class EventStream<A> extends Observable<A> implements HKT<EventStream<A>> {
    [Sym.HKT]: EventStream<A>;
    protected __isEventStream: true;
    constructor(dispatcherOrSubscribe: EventStreamDispatcher<A> | Subscribe<A>);
}
export declare function isEventStream<T>(x: any): x is EventStream<T>;
export declare class EventStreamDispatcher<T> extends Dispatcher<T> {
    private ended;
    subscribe(subscriber: Subscriber<T>, order: number): Subscription;
    end(tx: Transaction): void;
}