(WebSocket webSocket, ByteBuffer data, boolean last)
| 98 | final Zeze.Serialize.ByteBuffer input = Zeze.Serialize.ByteBuffer.Allocate(); |
| 99 | |
| 100 | @Override |
| 101 | public CompletionStage<?> onBinary(WebSocket webSocket, ByteBuffer data, boolean last) { |
| 102 | webSocket.request(1); |
| 103 | var n = data.remaining(); |
| 104 | input.EnsureWrite(n); |
| 105 | data.get(input.Bytes, input.WriteIndex, n); |
| 106 | input.WriteIndex += n; |
| 107 | if (last) { |
| 108 | var sc = Protocol.decode(clients.get(0).ClientService, input); |
| 109 | logger.info("Sc Web {}", sc != null ? sc.Argument : null); |
| 110 | input.Compact(); |
| 111 | } |
| 112 | return null; |
| 113 | } |
| 114 | }); |
| 115 | } |
| 116 |
nothing calls this directly
no test coverage detected