ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rppgrpc::details::base_writer< TData >::observer_strategy Struct Reference

Public Member Functions

template<rpp::constraint::decayed_same_as< TData > T>
void on_next (T &&message) const
 
void on_error (const std::exception_ptr &) const
 
void on_completed () const
 

Static Public Member Functions

static constexpr bool is_disposed ()
 
static constexpr void set_upstream (const rpp::disposable_wrapper &)
 

Public Attributes

std::reference_wrapper< base_writerowner {}
 

Static Public Attributes

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

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