ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::blocking_observable< Type, OriginalObservable > Class Template Referencefinal

blocking alternative of observable: provides interface where each function do blocking subscribe on original observable (waits till on_completed and provides value) More...

#include <blocking_observable.hpp>

Inheritance diagram for rpp::blocking_observable< Type, OriginalObservable >:
rpp::details::member_overload< Type, blocking_observable< Type, OriginalObservable >, details::subscribe_tag >

Public Member Functions

 blocking_observable (const OriginalObservable &original)
 
 blocking_observable (OriginalObservable &&original)
 

Friends

struct details::member_overload< Type, blocking_observable< Type, OriginalObservable >, details::subscribe_tag >
 

Detailed Description

template<constraint::decayed_type Type, constraint::observable_of_type< Type > OriginalObservable>
class rpp::blocking_observable< Type, OriginalObservable >

blocking alternative of observable: provides interface where each function do blocking subscribe on original observable (waits till on_completed and provides value)

Template Parameters
Typetype of values emitted by this observable
OriginalObservableoriginal observable wrapped by this observable

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