class TcpSocketRpcConnection implements RpcConnection {

    @Override
    public InputStream getIncomingStream() {
        try {
            return socket.getInputStream();
        } catch (IOException e) {
            log.error("Failed to get incoming stream", e);
            throw new RuntimeException(e);
        }
    }

    public  TcpSocketRpcConnection(Socket socket);

}