class AsyncRpcSender implements RpcSender {

    @Override
    public void attach(OutputStream outputStream) {
        Objects.requireNonNull(outputStream, "outputStream may not be null");
        log.info("Attached to output stream!");
        this.outgoingStream = outputStream;
    }

    public  AsyncRpcSender(ExecutorService executorService, ObjectMapper msgPacker);

}