public void process()

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();
            }
        }