@Override
	public InputBlockStream openBlockStream() throws IOException {

		Socket socket = connect();
		socket.setReceiveBufferSize(getPreferredBufferSize());

		return new ClientInputBlockStream(socket);
	}
<code>ClientInputBlockStream</code> provides the client-side of an
InputBlockStream which wraps an optionally compressed socket input stream
Ghidra/Features/GhidraServer/src/main/java/ghidra/server/stream/RemoteInputBlockStreamHandle.java