WebSocketTransport

WebSocket client interface.

Similar to HTTPClient design:

• Client instance is stateless and reusable

• Each connect() creates a new connection

• Connection configuration is passed via WebSocketRequest

• Supports generic type parameter for message format (String or byte[])

Implementations:

• JdkWebSocketTransport - Based on JDK 11+ HttpClient

• OkHttpWebSocketTransport - Based on OkHttp

Usage example (text protocol):

`// Create client (reusable)
WebSocketTransport client = JdkWebSocketTransport.create();

// Create connection request
WebSocketRequest request = WebSocketRequest.builder("wss://api.openai.com/v1/realtime")
.header("Authorization", "Bearer " + apiKey)
.build();

// Establish connection (specify String type)
client.connect(request, String.class)
.flatMapMany(connection -> {
// Send JSON configuration
connection.send(sessionConfig).subscribe();
// Receive JSON messages
return connection.receive();
})
.subscribe(json -> handleMessage(json));
`

Usage example (binary protocol):

`// Establish connection (specify byte[] type)
client.connect(request, byte[].class)
.flatMapMany(connection -> {
// Send binary data
connection.send(binaryFrame).subscribe();
// Receive binary data
return connection.receive();
})
.subscribe(data -> handleBinaryMessage(data));
`