ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
auto | get_observable () |
Protected Member Functions | |
virtual void | start_read (TData &data)=0 |
void | handle_read_done (bool initial=false) |
void | handle_on_done (std::exception_ptr err) |