SObjectizer-5 Extra
|
A builder for case when collecting_mbox collects messages. More...
#include <collecting_mbox.hpp>
Public Types | |
using | message_type = collected_messages_bunch_t< Config_Type > |
Actual message type to be used. More... | |
Public Member Functions | |
void | store (message_ref_t message, std::size_t messages_to_collect) |
Store another instance of collecting messages. More... | |
bool | is_ready_to_be_sent (std::size_t messages_to_collect) const noexcept |
std::unique_ptr< message_type > | extract_message () |
Private Attributes | |
std::unique_ptr< message_type > | m_current_msg |
The current instance of messages_collected to store messages to be delivered. More... | |
std::size_t | m_collected_messages = 0 |
Count of collected messages. More... | |
A builder for case when collecting_mbox collects messages.
Config_Type | a type with enumeration of all necessary type traits. It is expected to be config_type with appropriate type parameters. |
Definition at line 335 of file collecting_mbox.hpp.
using so_5::extra::mboxes::collecting_mbox::details::collected_messages_bunch_builder_t< Config_Type >::message_type = collected_messages_bunch_t< Config_Type > |
Actual message type to be used.
Definition at line 339 of file collecting_mbox.hpp.
|
inline |
Definition at line 397 of file collecting_mbox.hpp.
|
inlinenoexcept |
Definition at line 391 of file collecting_mbox.hpp.
|
inline |
Store another instance of collecting messages.
message | Message to be stored. |
messages_to_collect | Total count of message to be collected. This parameter is necessary because a new instance of messages_collected can be created inside this method. |
Definition at line 358 of file collecting_mbox.hpp.
|
private |
Count of collected messages.
If m_collected_messages != 0 then m_current_msg must not be nullptr.
Definition at line 353 of file collecting_mbox.hpp.
|
private |
The current instance of messages_collected to store messages to be delivered.
Can be nullptr if there is no new messages.
Definition at line 347 of file collecting_mbox.hpp.