WebSocketConnection

WebSocket connection interface.

Represents an active WebSocket connection with send/receive capabilities. Uses generic type parameter to support different message formats:

• WebSocketConnection<String> - Text protocol (JSON over WebSocket)

• WebSocketConnection<byte[]> - Binary protocol

Error handling: All methods return Mono/Flux that propagate errors through Reactor's error channel. Errors are wrapped in WebSocketTransportException with connection context.

Logging: Implementations should log at appropriate levels:

• INFO: Connection established/closed

• DEBUG: Message send/receive operations

• TRACE: Detailed message content (size, preview)

• ERROR: Connection errors, send/receive failures

Usage example (text protocol):

`WebSocketTransport client = JdkWebSocketTransport.create();
client.connect(request, String.class)
.flatMapMany(connection -> {
// Send JSON message
connection.send("{\"type\":\"config\"}").subscribe();

// Receive JSON messages
return connection.receive();
})
.subscribe(
json -> handleMessage(json),
error -> handleError(error) // WebSocketTransportException with context
);
`

Usage example (binary protocol):

`client.connect(request, byte[].class)
.flatMapMany(connection -> {
// Send binary message
connection.send(binaryData).subscribe();

// Receive binary messages
return connection.receive();
})
.subscribe(
data -> handleBinaryMessage(data),
error -> handleError(error)
);
`