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