Searched defs:_subscription (Results 1 – 7 of 7) sorted by relevance
58 private val _subscription = atomic<Disposable?>(null) constant
46 private val _subscription = atomic<Disposable?>(null) constant
32 private val _subscription = atomic<Subscription?>(null) constant in kotlinx.coroutines.reactive.SubscriptionChannel
214 const std::shared_ptr<remote_subscription> &_subscription, in update_remote_subscription()295 const std::shared_ptr<remote_subscription> &_subscription) { in is_remote_subscription_limit_reached()323 const std::shared_ptr<remote_subscription> &_subscription) { in add_remote_subscription()
2784 std::shared_ptr<remote_subscription> &_subscription, in on_remote_subscribe()2883 std::shared_ptr<remote_subscription> &_subscription) { in on_remote_unsubscribe()
77 const std::shared_ptr<remote_subscription> &_subscription) { in add_subscription()
312 const std::shared_ptr<subscription> &_subscription, in send_subscription()759 const std::shared_ptr<subscription> &_subscription, in create_eventgroup_entry()3218 const std::shared_ptr<remote_subscription> &_subscription) { in update_remote_subscription()3769 const std::shared_ptr<subscription>& _subscription) { in get_eventgroup_reliability()