request_stream_builder.h

#pragma once
 
#include <memory>
#include <utility>
#include <variant>
 
#include <ucxx/request_builder_base.h>
#include <ucxx/request_data.h>
 
namespace ucxx {
 
// Forward declarations
class Endpoint;
class Request;
class RequestStream;

class RequestStreamBuilder : public RequestBuilderBase<RequestStreamBuilder> {
 private:
  std::shared_ptr<Endpoint> _endpoint;  
  std::variant<data::StreamSend, data::StreamReceive>
    _requestData;  
 
 public:
  explicit RequestStreamBuilder(std::shared_ptr<Endpoint> endpoint,
                                std::variant<data::StreamSend, data::StreamReceive> requestData);

  [[nodiscard]] std::shared_ptr<RequestStream> build();

  operator std::shared_ptr<RequestStream>();

  operator std::shared_ptr<Request>();
};

[[nodiscard]] inline RequestStreamBuilder requestStreamBuilder(
  std::shared_ptr<Endpoint> endpoint,
  std::variant<data::StreamSend, data::StreamReceive> requestData)
{
  return RequestStreamBuilder(std::move(endpoint), std::move(requestData));
}
 
}  // namespace ucxx