Method run

src/main/java/core/packetproxy/DuplexAsync.java:93–108

()

		clientFlowSourceThread = new Thread(new Runnable() {

			public void run() {
				try {

					byte[] inputBuf = new byte[65536];
					int inputLen = 0;
					while ((inputLen = flow_controlled_client_input.read(inputBuf)) > 0) {

						callOnClientChunkFlowControl(ArrayUtils.subarray(inputBuf, 0, inputLen));
					}
					flow_controlled_client_input.close();
					closeOnClientChunkFlowControl();
				} catch (Exception e) {

					// errWithStackTrace(e);
				}
			}
		});

		serverFlowSourceThread = new Thread(new Runnable() {