Searched refs:sharedThis (Results 1 – 1 of 1) sorted by relevance
259 auto sharedThis = std::static_pointer_cast<const this_type>(this->shared_from_this()); in on_subscribe() local260 o.add([sharedThis, index]() { in on_subscribe()261 …sharedThis->sv[index] = rxn::subscription(sharedThis->sv[index].subscribe(), sharedThis->sc->clock… in on_subscribe()324 auto sharedThis = std::static_pointer_cast<const this_type>(this->shared_from_this()); in on_subscribe() local325 o.add([sharedThis, index, olocation]() { in on_subscribe()326 …sharedThis->sv[index] = rxn::subscription(sharedThis->sv[index].subscribe(), sharedThis->sc->clock… in on_subscribe()327 sharedThis->observers.erase(olocation); in on_subscribe()