Method receive

src/main/java/core/packetproxy/DuplexSync.java:87–125

()

	}

	@Override
	public byte[] receive() throws Exception {
		byte[] input_data = new byte[100 * 1024];

		ByteArrayOutputStream bin = new ByteArrayOutputStream();
		ByteArrayOutputStream bout = new ByteArrayOutputStream();

		int length = 0;
		while ((length = in.read(input_data, 0, input_data.length)) >= 0) {

			bin.write(input_data, 0, length);

			int packetLen = 0;
			while ((packetLen = callOnServerPacketReceived(bin.toByteArray())) > 0) {

				byte[] packetData = ArrayUtils.subarray(bin.toByteArray(), 0, packetLen);
				byte[] restData = ArrayUtils.subarray(bin.toByteArray(), packetLen, bin.size());
				bin.reset();
				bin.write(restData);

				callOnServerChunkArrived(packetData);

				byte[] available_data = callOnServerChunkAvailable();
				if (available_data == null || available_data.length == 0) {

					continue;
				}
				do {

					byte[] decoded = callOnServerChunkReceived(available_data);
					bout.write(decoded);
					available_data = callOnServerChunkAvailable();
				} while (available_data != null && available_data.length > 0);
				byte[] encoded = callOnServerChunkSend(bout.toByteArray());
				return encoded;
			}
		}
		return null;
	}

	@Override
	public void close() throws Exception {