|
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) |