1 #ifndef PROTON_CODEC_DECODER_HPP 2 #define PROTON_CODEC_DECODER_HPP 25 #include "../internal/data.hpp" 26 #include "../internal/type_traits.hpp" 27 #include "../types_fwd.hpp" 30 #include <proton/type_compat.h> 61 explicit decoder(
const data& d,
bool exact=
false) : data(d), exact_(exact) {}
65 PN_CPP_EXTERN
explicit decoder(
const internal::value_base&,
bool exact=
false);
69 PN_CPP_EXTERN
void decode(
const char* buffer,
size_t size);
73 PN_CPP_EXTERN
void decode(
const std::string&);
76 PN_CPP_EXTERN
bool more();
91 PN_CPP_EXTERN
decoder& operator>>(
bool&);
92 PN_CPP_EXTERN
decoder& operator>>(uint8_t&);
93 PN_CPP_EXTERN
decoder& operator>>(int8_t&);
94 PN_CPP_EXTERN
decoder& operator>>(uint16_t&);
95 PN_CPP_EXTERN
decoder& operator>>(int16_t&);
96 PN_CPP_EXTERN
decoder& operator>>(uint32_t&);
97 PN_CPP_EXTERN
decoder& operator>>(int32_t&);
98 PN_CPP_EXTERN
decoder& operator>>(
wchar_t&);
99 PN_CPP_EXTERN
decoder& operator>>(uint64_t&);
100 PN_CPP_EXTERN
decoder& operator>>(int64_t&);
102 PN_CPP_EXTERN
decoder& operator>>(
float&);
103 PN_CPP_EXTERN
decoder& operator>>(
double&);
108 PN_CPP_EXTERN
decoder& operator>>(std::string&);
114 PN_CPP_EXTERN
decoder& operator>>(internal::value_base&);
116 #if PN_CPP_HAS_NULLPTR 117 PN_CPP_EXTERN
decoder& operator>>(decltype(
nullptr)&);
132 template <
class T>
struct sequence_ref { T& ref; sequence_ref(T& r) : ref(r) {} };
133 template <
class T>
struct associative_ref { T& ref; associative_ref(T& r) : ref(r) {} };
134 template <
class T>
struct pair_sequence_ref { T& ref; pair_sequence_ref(T& r) : ref(r) {} };
136 template <
class T>
static sequence_ref<T> sequence(T& x) {
return sequence_ref<T>(x); }
137 template <
class T>
static associative_ref<T> associative(T& x) {
return associative_ref<T>(x); }
138 template <
class T>
static pair_sequence_ref<T> pair_sequence(T& x) {
return pair_sequence_ref<T>(x); }
147 if (s.is_described) next();
148 r.ref.resize(s.size);
149 for (
typename T::iterator i = r.ref.begin(); i != r.ref.end(); ++i)
156 using namespace internal;
161 for (
size_t i = 0; i < s.size/2; ++i) {
162 typename remove_const<typename T::key_type>::type k;
163 typename remove_const<typename T::mapped_type>::type v;
173 using namespace internal;
178 for (
size_t i = 0; i < s.size/2; ++i) {
179 typedef typename T::value_type value_type;
180 typename remove_const<typename value_type::first_type>::type k;
181 typename remove_const<typename value_type::second_type>::type v;
183 r.ref.push_back(value_type(k, v));
190 template <
class T,
class U>
decoder& extract(T& x, U (*
get)(pn_data_t*));
198 template<
class T> T
get(
decoder& d) {
208 template <
class T>
typename internal::enable_if<internal::is_unknown_integer<T>::value,
decoder&>::type
210 using namespace internal;
211 typename integer_type<sizeof(T), is_signed<T>::value>::type v;
220 #endif // PROTON_CODEC_DECODER_HPP A holder for an instance of any scalar AMQP type.
Definition: scalar.hpp:37
An AMQP message.
Definition: message.hpp:50
Unsettled API - Start encoding a complex type.
Definition: common.hpp:34
A key for use with AMQP annotation maps.
Definition: annotation_key.hpp:38
A sequence of key-value pairs.
Definition: type_id.hpp:62
A 16-byte universally unique identifier.
Definition: uuid.hpp:37
decoder & operator>>(sequence_ref< T > r)
Extract any AMQP sequence (ARRAY, LIST or MAP) to a C++ sequence container of T if the elements types...
Definition: decoder.hpp:144
decoder & operator>>(associative_ref< T > r)
Extract an AMQP MAP to a C++ associative container.
Definition: decoder.hpp:155
A 64-bit decimal floating-point value.
Definition: decimal.hpp:49
Unsettled API - Shared codec functions.
A string that represents the AMQP symbol type.
Definition: symbol.hpp:35
Arbitrary binary data.
Definition: binary.hpp:40
A 128-bit decimal floating-point value.
Definition: decimal.hpp:52
type_id
An identifier for AMQP types.
Definition: type_id.hpp:37
A 32-bit decimal floating-point value.
Definition: decimal.hpp:46
A 64-bit timestamp in milliseconds since the Unix epoch.
Definition: timestamp.hpp:35
decoder & operator>>(pair_sequence_ref< T > r)
Extract an AMQP MAP to a C++ push_back sequence of pairs preserving encoded order.
Definition: decoder.hpp:172
void assert_type_equal(type_id want, type_id got)
Throw a conversion_error if want != got with a message including the names of the types...
internal::enable_if< internal::is_unknown_integer< T >::value, decoder & >::type operator>>(decoder &d, T &i)
operator>> for integer types that are not covered by the standard overrides.
Definition: decoder.hpp:209
Unsettled API - Finish inserting or extracting a complex type.
Definition: common.hpp:57
decoder(const data &d, bool exact=false)
Wrap a Proton C data object.
Definition: decoder.hpp:61
type_id next_type()
Get the type of the next value that will be read by operator>>.
The main Proton namespace.
Definition: annotation_key.hpp:33
void decode(const char *buffer, size_t size)
Decode AMQP data from a buffer and add it to the end of the decoders stream.
The type of the AMQP null value.
Definition: null.hpp:39
Unsettled API - A stream-like decoder from AMQP bytes to C++ values.
Definition: decoder.hpp:56
An AMQP message ID.
Definition: message_id.hpp:47
bool more()
Return true if there are more value to extract at the current level.