/// <reference types="node" />
import { Observable } from 'rxjs';
import { SocketWithInfo } from './types';
import { Logger } from '../logging';
import { IAction } from '../action';
export declare const defaultSendToSocket: <T extends IAction | Buffer>(socket: SocketWithInfo, data: T) => Promise<void>;
declare const defaultSendToSocketErrorHandler: <T>(data: T, error: Error, logger: Logger) => void;
declare const defaultCloseSocket: (socket: SocketWithInfo, code?: number | undefined) => void;
export declare const pipeStreamIntoSocket: <T extends IAction | Buffer>(stream: Observable<T>, socket: SocketWithInfo, optsRaw?: Partial<{
    close: typeof defaultCloseSocket;
    send: typeof defaultSendToSocket;
    logger: Logger;
    onSendError: typeof defaultSendToSocketErrorHandler;
    closeOnError: boolean;
    closeOnComplete: boolean;
}> | undefined) => import("rxjs").Subscription;
export {};