connection-pipeline.hxx

Go to the documentation of this file.

#ifndef PQXX_INTERNAL_GATES_CONNECTION_PIPELINE_HXX
#define PQXX_INTERNAL_GATES_CONNECTION_PIPELINE_HXX
 
#include <pqxx/internal/callgate.hxx>
 
#include "pqxx/pipeline.hxx"
 
namespace pqxx::internal::gate
{
class PQXX_PRIVATE connection_pipeline final : callgate<connection>
{
  friend class pqxx::pipeline;
 
  explicit constexpr connection_pipeline(reference x) noexcept : super(x) {}
 
  PQXX_ZARGS void start_exec(char const query[]) { home().start_exec(query); }
  [[nodiscard]] pqxx::internal::pq::PGresult *get_result()
  {
    return home().get_result();
  }
  void cancel_query(sl loc) { home().cancel_query(loc); }
 
  bool consume_input() noexcept { return home().consume_input(); }
  [[nodiscard]] bool is_busy() const noexcept { return home().is_busy(); }
 
  [[nodiscard]] int encoding_id(sl loc) const
  {
    return home().encoding_id(loc);
  }
 
  [[nodiscard]] auto get_notice_waiters() const
  {
    return home().m_notice_waiters;
  }
};
} // namespace pqxx::internal::gate
#endif