import { Subscription } from 'rxjs';
import { SocketWithInfo, MessageWithInfo } from './types';
import { AnySocketEpic } from '../kit';
import { RegistryStateApi } from './socketRegistryState';
import { BasicLogger } from '../logging';
export declare const spinUpSocketEpic: (socket: SocketWithInfo, request: MessageWithInfo, epic: AnySocketEpic, closeSocket: RegistryStateApi['closeSocket'], parentLogger: BasicLogger) => {
    subscription: Subscription;
    waitForCompletion: () => Promise<"completed" | "timed-out">;
};