Searched defs:safe_subscriber (Results 1 – 1 of 1) sorted by relevance
433 struct safe_subscriber struct435 …safe_subscriber(SourceOperator& so, Subscriber& o) : so(std::addressof(so)), o(std::addressof(o)) … in safe_subscriber() argument437 void subscribe() { in subscribe()449 void operator()(const rxsc::schedulable&) { in operator ()()453 SourceOperator* so;454 Subscriber* o;