blob: 598c2260e4ec3bb04d71cee294b1c82ba3cc75e9 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
/** Implementation of the pqxx::stream_base class.
*
* pqxx::stream_base provides optimized batch access to a database table.
*
* Copyright (c) 2000-2019, Jeroen T. Vermeulen.
*
* See COPYING for copyright license. If you did not receive a file called
* COPYING with this source code, please notify the distributor of this mistake,
* or contact the author.
*/
#include "pqxx/compiler-internal.hxx"
#include "pqxx/stream_base.hxx"
#include "pqxx/transaction"
pqxx::stream_base::stream_base(transaction_base &tb) :
internal::namedclass("stream_base"),
internal::transactionfocus{tb},
m_finished{false}
{}
pqxx::stream_base::operator bool() const noexcept
{
return not m_finished;
}
bool pqxx::stream_base::operator!() const noexcept
{
return not static_cast<bool>(*this);
}
void pqxx::stream_base::close()
{
if (*this)
{
m_finished = true;
unregister_me();
}
}
|
