class ReactiveRpcStreamerWrapper implements ReactiveRpcStreamer {

    @Override
    public CompletableFuture<ResponseMessage> response(RequestMessage.Builder requestMessage) {
        if (executor == null) {
            return CompletableFuture.supplyAsync(responseSupplier(requestMessage));
        } else {
            return CompletableFuture.supplyAsync(responseSupplier(requestMessage), executor);
        }
    }

    public  ReactiveRpcStreamerWrapper(RpcStreamer rpcStreamer);
    public  ReactiveRpcStreamerWrapper(RpcStreamer rpcStreamer, Executor executor);

}