generic-library/cppzmq
1
0
Fork 0
mirror of https://github.com/zeromq/cppzmq.git synced 2025-06-17 19:26:23 +02:00
Code Issues Projects Releases Wiki Activity

Merge pull request #124 from vtellier/patch-1

Browse Source 
Added peekstr and peektyp methods
This commit is contained in:
Luca Boccassi 2017-06-07 09:29:03 +01:00 committed by GitHub
commit b544d86c5f
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
zmq_addon.hpp
View File

@ -1,5 +1,5 @@
/* /*
Copyright (c) 2016 VOCA AS / Harald Nøkland Copyright (c) 2016 VOCA AS / Harald Nøkland
Permission is hereby granted, free of charge, to any person obtaining a copy Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to of this software and associated documentation files (the "Software"), to
@ -36,7 +36,7 @@ namespace zmq {
/* /*
This class handles multipart messaging. It is the C++ equivalent of zmsg.h, This class handles multipart messaging. It is the C++ equivalent of zmsg.h,
which is part of CZMQ (the high-level C binding). Furthermore, it is a major which is part of CZMQ (the high-level C binding). Furthermore, it is a major
improvement compared to zmsg.hpp, which is part of the examples in the ØMQ improvement compared to zmsg.hpp, which is part of the examples in the ØMQ
Guide. Unnecessary copying is avoided by using move semantics to efficiently Guide. Unnecessary copying is avoided by using move semantics to efficiently
add/remove parts. add/remove parts.
*/ */
@ -328,6 +328,23 @@ public:
return &m_parts[index]; return &m_parts[index];
} }
// Get a string copy of a specific message part
std::string peekstr(size_t index) const
{
std::string string(m_parts[index].data<char>(), m_parts[index].size());
return string;
}
// Peek type (fixed-size) from front
template<typename T>
T peektyp(size_t index)
{
static_assert(!std::is_same<T, std::string>::value, "Use peekstr() instead of peektyp<std::string>()");
if(sizeof(T) != m_parts.front().size())
throw std::runtime_error("Invalid type, size does not match the message size");
T type = *m_parts[index].data<T>();
}
// Create multipart from type (fixed-size) // Create multipart from type (fixed-size)
template<typename T> template<typename T>
static multipart_t create(const T& type) static multipart_t create(const T& type)