#include <buffer.hpp>
Public Member Functions | |
buffer_state (size_t count) | |
buffer_state (const buffer_state &other)=delete | |
buffer_state (buffer_state &&) noexcept=default | |
buffer_state & | operator= (const buffer_state &)=delete |
buffer_state & | operator= (buffer_state &&) noexcept=default |
void | clear_and_reserve_buckets () const |
Public Attributes | |
const size_t | max |
buffer_bundle_type< UpstreamType > | buckets |
A non-copyable class that provides a copyable on_next for the subscriber and allows copies of on_next(s) to share the same states.
|
inlineexplicit |
count | Number of items being bundled. Note when count == 0, we'll treat the behavior like when count == 1. |