1#include "pqxx/internal/libpq-forward.hxx"
2#include <pqxx/internal/callgate.hxx>
4#include "pqxx/pipeline.hxx"
6namespace pqxx::internal::gate
8class PQXX_PRIVATE connection_pipeline : callgate<connection>
10 friend class pqxx::pipeline;
12 connection_pipeline(reference x) : super(x) {}
14 void start_exec(
char const query[]) { home().start_exec(query); }
15 pqxx::internal::pq::PGresult *get_result() {
return home().get_result(); }
16 void cancel_query() { home().cancel_query(); }
18 bool consume_input() noexcept {
return home().consume_input(); }
19 bool is_busy() const noexcept {
return home().is_busy(); }
21 int encoding_id() {
return home().encoding_id(); }