|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Classes | |
| struct | observer_strategy |
Public Member Functions | |
| auto | get_observer () const |
Protected Member Functions | |
| virtual void | start_write (const TData &v)=0 |
| virtual void | finish_writes (const grpc::Status &status)=0 |
| void | handle_on_done () |
| void | handle_write_done () |