import { Socket } from "socket.io";
import { AuthMessage, Transport } from "@bsv/sdk";
//#region src/SocketServerTransport.d.ts
interface SocketServerTransportOptions {
  /** Maximum authentication messages that may be processed concurrently per socket. */
  maxPendingMessages?: number;
  /** Receives contained authentication failures. The hook is never allowed to throw outward. */
  onError?: (error: unknown) => void | Promise<void>;
}
/**
 * Implements the Transport interface for a specific client socket.
 *
 * This transport simply relays AuthMessages over 'authMessage'
 * in the underlying Socket.IO connection.
 */
declare class SocketServerTransport implements Transport {
  private readonly socket;
  private readonly maxPendingMessages;
  private readonly onError?;
  private pendingMessages;
  private failed;
  constructor(socket: Socket, options?: SocketServerTransportOptions);
  send(message: AuthMessage): Promise<void>;
  onData(callback: (message: AuthMessage) => Promise<void>): Promise<void>;
  private processMessage;
  private fail;
}
//#endregion
export { SocketServerTransport, SocketServerTransportOptions };
//# sourceMappingURL=SocketServerTransport.d.mts.map