CAF
0.17.6
|
Acknowledges a previous open
message and finalizes a stream handshake.
More...
#include <upstream_msg.hpp>
Public Types | |
using | outer_type = upstream_msg |
Allows the testing DSL to unbox this type automagically. | |
Public Attributes | |
actor_addr | rebind_from |
Allows actors to participate in a stream instead of the actor originally receiving the open message. More... | |
strong_actor_ptr | rebind_to |
Points to sender_, but with a strong reference. | |
int32_t | initial_demand |
Grants credit to the source. | |
int32_t | desired_batch_size |
Desired size of individual batches. | |
Related Functions | |
(Note that these are not member functions.) | |
template<class Inspector > | |
Inspector::result_type | inspect (Inspector &f, upstream_msg::ack_open &x) |
Acknowledges a previous open
message and finalizes a stream handshake.
Also signalizes initial demand.
|
related |
actor_addr caf::upstream_msg::ack_open::rebind_from |
Allows actors to participate in a stream instead of the actor originally receiving the open
message.
No effect when set to nullptr
. This mechanism enables pipeline definitions consisting of proxy actors that are replaced with actual actors on demand.