class PackStream implements RpcStreamer {

    @Override
    public void send(Message message) throws IOException {
        log.debug("Sending message: {}", message);
        rpcSender.send(message);
    }

    public  PackStream(RpcSender rpcSender, RpcListener rpcListener);
    public  PackStream(RpcSender rpcSender, RpcListener rpcListener, MessageIdGenerator messageIdGenerator);

}