|
| | SingleKeyWriter (const Topic< Key, Value, UpdateTag > &topic, const Key &key, const std::string &name=std::string(), const WriterConfig &config=WriterConfig()) noexcept |
| | Construct a new writer for the given key. More...
|
| |
| | SingleKeyWriter (SingleKeyWriter &&writer) noexcept |
| | Move constructor. More...
|
| |
| SingleKeyWriter & | operator= (SingleKeyWriter &&writer) noexcept |
| | Move assignement operator. More...
|
| |
| void | add (const Value &value) noexcept |
| | Add the data element. More...
|
| |
| void | update (const Value &value) noexcept |
| | Update the data element. More...
|
| |
| template<typename UpdateValue > |
| std::function< void(const UpdateValue &)> | partialUpdate (const UpdateTag &tag) noexcept |
| | Get a partial udpate generator function for the given partial update tag. More...
|
| |
| void | remove () noexcept |
| | Remove the data element. More...
|
| |
| | Writer (Writer &&writer) noexcept |
| | Transfers the given writer to this writer. More...
|
| |
| Writer & | operator= (Writer &&writer) noexcept |
| | Move assignement operator. More...
|
| |
| | ~Writer () |
| | Destruct the writer. More...
|
| |
| bool | hasReaders () const noexcept |
| | Indicates whether or not readers are online. More...
|
| |
| void | waitForReaders (unsigned int count=1) const |
| | Wait for given number of readers to be online. More...
|
| |
| void | waitForNoReaders () const |
| | Wait for readers to be offline. More...
|
| |
| std::vector< std::string > | getConnectedReaders () const noexcept |
| | Get the connected readers. More...
|
| |
| std::vector< Key > | getConnectedKeys () const noexcept |
| | Get the keys for which readers are connected to this writer. More...
|
| |
| Sample< Key, Value, UpdateTag > | getLast () |
| | Get the last written sample. More...
|
| |
| std::vector< Sample< Key, Value, UpdateTag > > | getAll () noexcept |
| | Get all the written sample kept in the writer history. More...
|
| |
| void | onConnectedKeys (std::function< void(std::vector< Key >)> init, std::function< void(CallbackReason, Key)> update) noexcept |
| | Calls the given functions to provide the initial set of connected keys and when a key is added or removed from the set of connected keys. More...
|
| |
| void | onConnectedReaders (std::function< void(std::vector< std::string >)> init, std::function< void(CallbackReason, std::string)> update) noexcept |
| | Calls the given functions to provide the initial set of connected readers and when a new reader connects or disconnects. More...
|
| |
template<typename Key, typename Value, typename UpdateTag = std::string>
class DataStorm::SingleKeyWriter< Key, Value, UpdateTag >
The key writer to write the data element associated with a given key.
template<typename Key , typename Value , typename UpdateTag >
template<typename UpdateValue >
| std::function< void(const UpdateValue &)> DataStorm::SingleKeyWriter< Key, Value, UpdateTag >::partialUpdate |
( |
const UpdateTag & |
tag | ) |
|
|
noexcept |
Get a partial udpate generator function for the given partial update tag.
When called, the returned function generates a PartialUpdate sample with the given partial update value.
The UpdateValue template parameter must match the UpdateValue type used to register the updater with the Topic::setUpdater method.
- Parameters
-
| tag | The partial update tag. |