class PackStream implements RpcStreamer {

    @Override
    public void attach(RpcConnection rpcConnection) {
        Objects.requireNonNull(rpcConnection, "rpcConnection may not be null");
        log.info("Attaching PackStream to: {}", rpcConnection);
        startListening(rpcConnection.getIncomingStream());
        rpcSender.attach(rpcConnection.getOutgoingStream());
    }

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

}