Method run

src/main/java/core/packetproxy/ProxyQuicForward.java:36–61

()

	}

	@Override
	public void run() {
		try {

			while (true) {

				ClientConnection clientConnection = this.clientConnections.accept();
				log("accept");

				String serverName = this.listen_info.getServer().getIp();
				log("[QUIC-forward!] %s", serverName);

				ServerConnection serverConnection = new ServerConnection(ConnectionIdPair.generateRandom(), serverName,
						this.listen_info.getPort());

				DuplexAsync duplex = DuplexFactory.createDuplexAsync(clientConnection, serverConnection,
						this.listen_info.getServer().getEncoder());

				duplex.start();
				DuplexManager.getInstance().registerDuplex(duplex);
			}
		} catch (Exception e) {

			errWithStackTrace(e);
		}
	}

	public void close() throws Exception {
		this.clientConnections.close();