ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rpp::operators::details::delay_observer_strategy< Observer, Worker, Container, ClearOnError > Struct Template Reference

Public Member Functions

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

Public Attributes

std::shared_ptr< delay_disposable< Observer, Worker, Container > > disposable {}
 

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: