/// <reference types="node" />
/// <reference types="pouchdb-core" />
import { Duplex } from 'stream';
import { Endpoint } from './types';
export interface PeerOptions<Message> {
    readonly endpoint: Endpoint;
    readonly stream: Duplex;
    readonly transform: Duplex;
    readonly onError: (peer: Peer<Message>, error: Error) => void;
    readonly onClose: (peer: Peer<Message>) => void;
}
export declare abstract class Peer<Message> {
    readonly endpoint: Endpoint;
    private readonly stream;
    private readonly transform;
    private readonly buffer;
    private mutableConnected;
    private mutableConnecting;
    private mutableClosed;
    private readonly onErrorInternal;
    private readonly onCloseInternal;
    constructor(options: PeerOptions<Message>);
    readonly connected: boolean;
    connect(): Promise<void>;
    close(hadError?: boolean): void;
    write(buffer: Buffer): void;
    receiveMessage(timeoutMS?: number): Promise<Message>;
    streamData(onDataReceived: (data: Message) => void): {
        readonly unsubscribe: () => void;
    };
    protected abstract connectInternal(): Promise<void>;
    protected abstract closeInternal(hadError: boolean): void;
    protected onError(error: Error): void;
    private onClose;
}