ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::details::buffer_state< UpstreamType > Struct Template Reference

#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_stateoperator= (const buffer_state &)=delete
 
buffer_stateoperator= (buffer_state &&) noexcept=default
 
void clear_and_reserve_buckets () const
 

Public Attributes

const size_t max
 
buffer_bundle_type< UpstreamType > buckets
 

Detailed Description

template<constraint::decayed_type UpstreamType>
struct rpp::details::buffer_state< UpstreamType >

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.

Constructor & Destructor Documentation

◆ buffer_state()

template<constraint::decayed_type UpstreamType>
rpp::details::buffer_state< UpstreamType >::buffer_state ( size_t  count)
inlineexplicit
Parameters
countNumber of items being bundled. Note when count == 0, we'll treat the behavior like when count == 1.

The documentation for this struct was generated from the following file: