#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

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

template<constraint::decayed_type UpstreamType>

rpp::details::buffer_state< UpstreamType >::buffer_state ( size_t count )

inlineexplicit

Parameters

count Number 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: