ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rpp::operators::details::reduce_observer_strategy< TObserver, Accumulator > Struct Template Reference

Public Types

using Seed = rpp::utils::extract_observer_type_t<TObserver>

Public Member Functions

template<typename T>
void on_next (T &&v) const
void on_error (const std::exception_ptr &err) const
void on_completed () const
void set_upstream (const disposable_wrapper &d)
bool is_disposed () const

Public Attributes

RPP_NO_UNIQUE_ADDRESS TObserver observer
RPP_NO_UNIQUE_ADDRESS Seed seed
RPP_NO_UNIQUE_ADDRESS Accumulator accumulator

Static Public Attributes

static constexpr auto preferred_disposables_mode = rpp::details::observers::disposables_mode::None

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