(SocketChannel clientChannel, SocketChannel targetChannel)
| 224 | } |
| 225 | |
| 226 | private void startForwarding(SocketChannel clientChannel, SocketChannel targetChannel) { |
| 227 | Thread clientToTarget = new Thread(() -> forward(clientChannel, targetChannel)); |
| 228 | Thread targetToClient = new Thread(() -> forward(targetChannel, clientChannel)); |
| 229 | |
| 230 | clientToTarget.start(); |
| 231 | targetToClient.start(); |
| 232 | } |
| 233 | |
| 234 | private void forward(SocketChannel source, SocketChannel destination) { |
| 235 | ByteBuffer buffer = ByteBuffer.allocate(8192); |
no test coverage detected