in src/main/java/com/microsoft/azure/proton/transport/ws/impl/WebSocketImpl.java [451:468]
public void process() throws TransportException {
if (isWebSocketEnabled) {
inputBuffer.flip();
switch (webSocketState) {
case PN_WS_CONNECTING:
case PN_WS_CONNECTED_FLOW:
processInput();
break;
case PN_WS_NOT_STARTED:
case PN_WS_FAILED:
default:
underlyingInput.process();
}
} else {
underlyingInput.process();
}
}