|
C++ Actor Framework 0.18
|
Cumulatively acknowledges received batches and signalizes new demand from a sink to its source. More...
#include <upstream_msg.hpp>
Public Types | |
| using | outer_type = upstream_msg |
| Allows the testing DSL to unbox this type automagically. | |
Public Attributes | |
| int32_t | new_capacity |
| Newly available credit. | |
| int32_t | desired_batch_size |
| Desired size of individual batches for the next cycle. | |
| int64_t | acknowledged_id |
| Cumulative ack ID. | |
Cumulatively acknowledges received batches and signalizes new demand from a sink to its source.