import type { IncomingMessage } from 'http';
import { Observable } from 'rxjs';
import type { Socket, Server, NetConnectOpts } from 'net';
import WebSocket from 'ws';
/**
 * Calculates the full request URL for the given message.
 * @param request The request.
 * @param protocol The protocol.
 */
export declare function requestUrl(request: IncomingMessage, protocol: string): URL;
/**
 * Opens a socket connection.
 * @param options The options.
 */
export declare function connect(options: NetConnectOpts): Observable<Socket>;
/**
 * Listens for connections with the given server on the given port.
 * @param server The server.
 * @param port The port to listen on.
 */
export declare function listen(server: Server, port?: number): Observable<Socket>;
/**
 * Wraps the given socket in an observable.
 * @param connection The socket to wrap.
 */
export declare function cleanup(socket: Socket): Observable<Socket>;
/**
 * Opens a websocket connection to the given address.
 * @param address The address to open the connection to.
 * @param options The options to use.
 */
export declare function websocket(address: string, options?: WebSocket.ClientOptions): Observable<WebSocket>;
export declare function handleUpgrade(server: WebSocket.Server, req: IncomingMessage, socket: Socket, head: Buffer): Observable<WebSocket>;
/**
 * Gets an observable list of messages from the given websocket.
 * @param websocket The websocket.
 */
export declare function messages(websocket: WebSocket): Observable<WebSocket.Data>;
export declare function completeWith<T>(observable: Observable<any>): import("rxjs").MonoTypeOperatorFunction<T>;
//# sourceMappingURL=utils.d.ts.map