import { FinallyFunc } from "finally-provider";
import { LogProv } from "@jawis/jab";
import { NodeWS, SocketData, WsMessageListener, WebsocketRequestHandler } from "./internal";
export type WsPoolProv<MS extends SocketData, MR extends SocketData> = Readonly<{
    send: (data: MS) => void;
    forAll: (cb: (nws: NodeWS<MS, MR>) => void) => void;
    makeUpgradeHandler: (onMessage: WsMessageListener<MS, MR>) => WebsocketRequestHandler;
    shutdown: () => Promise<void>;
}>;
type Deps = {
    onError: (error: unknown) => void;
    logProv: LogProv;
    finally: FinallyFunc;
};
/**
 * Manage the WebSocket connection for a single express route.
 *
 * - This allows sending messages to only those connected to this specific route.
 */
export declare class WsPoolController<MS extends SocketData, MR extends SocketData> implements WsPoolProv<MS, MR> {
    private deps;
    clients: Set<NodeWS<MS, MR>>;
    constructor(deps: Deps);
    /**
     *
     */
    send: (data: MS) => void;
    /**
     *
     */
    forAll: (cb: (client: NodeWS<MS, MR>) => void) => void;
    /**
     *
     */
    makeUpgradeHandler: (onMessage: WsMessageListener<MS, MR>) => WebsocketRequestHandler;
    /**
     *
     */
    shutdown: () => Promise<void>;
}
export {};