Searched refs:subscriber_ (Results 1 – 1 of 1) sorted by relevance
326 subscriber_ = std::move(subscriber); in Subscribe()337 if (!subscriber_->is_subscribed()) { in OnNext()356 subscriber_->on_next(std::cref(e)); in OnNext()365 subscriber_->on_completed(); in OnCompleted()387 std::optional<rxcpp::subscriber<RefWrapper>> subscriber_; member