import { MaybeOptionalOptions } from '@orpc/shared'; import { C as Context, R as Router } from '../../shared/server.qKsRrdxW.js'; import { f as StandardHandler } from '../../shared/server.7cEtMB30.js'; import { HandleStandardServerPeerMessageOptions } from '../standard-peer/index.js'; import { S as StandardRPCHandlerOptions } from '../../shared/server.yoEB3Fx4.js'; import '@orpc/client'; import '@orpc/contract'; import '@orpc/standard-server'; import '@orpc/standard-server-peer'; import '../../shared/server.EfTOZ2Q7.js'; import '@orpc/client/standard'; import '../../shared/server.ChyoA9XY.js'; type MinimalWebsocket = Pick; declare class WebsocketHandler { #private; constructor(standardHandler: StandardHandler); /** * Upgrades a WebSocket to enable handling * * This attaches the necessary 'message' and 'close' listeners to the WebSocket * * @warning Do not use this method if you're using `.message()` or `.close()` */ upgrade(ws: MinimalWebsocket, ...rest: MaybeOptionalOptions>): void; /** * Handles a single message received from a WebSocket. * * @warning Avoid calling this directly if `.upgrade()` is used. * * @param ws The WebSocket instance * @param data The message payload, usually place in `event.data` */ message(ws: MinimalWebsocket, data: string | ArrayBuffer | Blob, ...rest: MaybeOptionalOptions>): Promise; /** * Closes the WebSocket peer and cleans up. * * @warning Avoid calling this directly if `.upgrade()` is used. */ close(ws: MinimalWebsocket): void; } interface RPCHandlerOptions extends StandardRPCHandlerOptions { } /** * RPC Handler for Websocket adapter * * @see {@link https://orpc.dev/docs/rpc-handler RPC Handler Docs} * @see {@link https://orpc.dev/docs/adapters/websocket Websocket Adapter Docs} */ declare class RPCHandler extends WebsocketHandler { constructor(router: Router, options?: NoInfer>); } export { RPCHandler, WebsocketHandler }; export type { MinimalWebsocket, RPCHandlerOptions };