| /external/openscreen/cast/sender/public/ |
| D | cast_app_discovery_service.h | 24 class Subscription {
26 Subscription(CastAppDiscoveryService* discovery_service, uint32_t id);
27 Subscription(Subscription&&) noexcept;
28 Subscription(Subscription&) = delete;
29 Subscription& operator=(Subscription&&);
30 Subscription& operator=(const Subscription&) = delete;
31 ~Subscription();
38 void Swap(Subscription& other);
53 virtual Subscription StartObservingAvailability(
|
| D | cast_app_discovery_service.cc | 10 CastAppDiscoveryService::Subscription::Subscription( in Subscription() function in openscreen::cast::CastAppDiscoveryService::Subscription
15 CastAppDiscoveryService::Subscription::Subscription( in Subscription() function in openscreen::cast::CastAppDiscoveryService::Subscription
16 Subscription&& other) noexcept in Subscription()
21 CastAppDiscoveryService::Subscription&
22 CastAppDiscoveryService::Subscription::operator=(Subscription&& other) { in operator =()
29 CastAppDiscoveryService::Subscription::~Subscription() { in ~Subscription()
33 void CastAppDiscoveryService::Subscription::Reset() { in Reset()
40 void CastAppDiscoveryService::Subscription::Swap(Subscription& other) { in Swap()
|
| /external/llvm-project/clang-tools-extra/clangd/support/ |
| D | Function.h | 38 class LLVM_NODISCARD Subscription {
42 Subscription(Event *Parent, unsigned ListenerID) in Subscription() function
47 Subscription() : Parent(nullptr) {} in Subscription() function
48 Subscription(Subscription &&Other) : Parent(nullptr) { in Subscription() function
51 Subscription &operator=(Subscription &&Other) {
66 ~Subscription() { in ~Subscription()
68 *this = Subscription(); // Unsubscribe. in ~Subscription()
75 Subscription observe(Listener L) { in observe()
78 return Subscription(this, ListenerCount); in observe()
|
| /external/libchrome/base/ |
| D | callback_list_unittest.cc | 41 std::unique_ptr<CallbackList<void(void)>::Subscription> sub) { in SetSubscriptionToRemove()
49 std::unique_ptr<CallbackList<void(void)>::Subscription> removal_subscription_;
77 std::unique_ptr<CallbackList<void(void)>::Subscription> subscription_;
121 std::unique_ptr<CallbackList<void(int)>::Subscription> subscription1 = in TEST()
128 std::unique_ptr<CallbackList<void(int, int)>::Subscription> subscription2 = in TEST()
135 std::unique_ptr<CallbackList<void(int, int, int)>::Subscription> in TEST()
142 std::unique_ptr<CallbackList<void(int, int, int, int)>::Subscription> in TEST()
149 std::unique_ptr<CallbackList<void(int, int, int, int, int)>::Subscription> in TEST()
157 CallbackList<void(int, int, int, int, int, int)>::Subscription> in TEST()
170 std::unique_ptr<CallbackList<void(void)>::Subscription> a_subscription = in TEST()
[all …]
|
| D | callback_list.h | 75 class Subscription {
77 Subscription(CallbackListBase<CallbackType>* list, in Subscription() function
83 ~Subscription() { in ~Subscription()
97 DISALLOW_COPY_AND_ASSIGN(Subscription);
103 std::unique_ptr<Subscription> Add(const CallbackType& cb) WARN_UNUSED_RESULT { in Add()
105 return std::make_unique<Subscription>( in Add()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | FlowAsPublisherTest.kt | 26 private lateinit var subscription: Subscription in <lambda>()
32 override fun onSubscribe(s: Subscription?) { in <lambda>()
56 private lateinit var subscription: Subscription in <lambda>()
62 override fun onSubscribe(s: Subscription?) { in <lambda>()
87 private lateinit var subscription: Subscription in <lambda>()
89 override fun onSubscribe(s: Subscription) { in <lambda>()
124 private lateinit var subscription: Subscription in <lambda>()
126 override fun onSubscribe(s: Subscription) { in <lambda>()
|
| D | IterableFlowTckTest.kt | 16 import org.reactivestreams.Subscription
44 override fun onSubscribe(s: Subscription) { in createFailedPublisher()
61 private lateinit var s: Subscription in testStackOverflowTrampoline()
63 override fun onSubscribe(s: Subscription) { in testStackOverflowTrampoline()
96 private var s: Subscription? = null in testConcurrentRequest()
98 override fun onSubscribe(s: Subscription) { in testConcurrentRequest()
|
| D | PublishTest.kt | 21 override fun onSubscribe(s: Subscription?) { expect(3) } in <lambda>()
41 override fun onSubscribe(s: Subscription) { in <lambda>()
66 override fun onSubscribe(s: Subscription) { in <lambda>()
100 var sub: Subscription? = null in <lambda>()
106 override fun onSubscribe(s: Subscription) { in <lambda>()
143 override fun onSubscribe(s: Subscription) { in <lambda>()
|
| D | PublisherBackpressureTest.kt | 29 var sub: Subscription? = null in <lambda>()
31 override fun onSubscribe(s: Subscription) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublishTest.kt | 21 override fun onSubscribe(s: JFlow.Subscription?) { expect(3) } in <lambda>()
41 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>()
66 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>()
100 var sub: JFlow.Subscription? = null in <lambda>()
106 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>()
143 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>()
|
| D | FlowAsPublisherTest.kt | 26 private lateinit var subscription: JFlow.Subscription in testErrorOnCancellationIsReported()
32 override fun onSubscribe(s: JFlow.Subscription?) { in testErrorOnCancellationIsReported()
56 private lateinit var subscription: JFlow.Subscription in testCancellationIsNotReported()
62 override fun onSubscribe(s: JFlow.Subscription?) { in testCancellationIsNotReported()
|
| D | PublisherBackpressureTest.kt | 29 var sub: JFlow.Subscription? = null in <lambda>()
31 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowAsFlowableTest.kt | 24 private lateinit var subscription: Subscription in <lambda>()
26 override fun onSubscribe(s: Subscription) { in <lambda>()
61 private lateinit var subscription: Subscription in <lambda>()
63 override fun onSubscribe(s: Subscription) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowAsFlowableTest.kt | 24 private lateinit var subscription: Subscription in <lambda>()
26 override fun onSubscribe(s: Subscription) { in <lambda>()
61 private lateinit var subscription: Subscription in <lambda>()
63 override fun onSubscribe(s: Subscription) { in <lambda>()
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/base/ |
| D | utilities.py | 30 class _Subscription(base.Subscription,
41 _NONE_SUBSCRIPTION = _Subscription(base.Subscription.Kind.NONE, None, None,
70 return _Subscription(base.Subscription.Kind.FULL, None, None, operator,
|
| /external/grpc-grpc/examples/ruby/pubsub/tech/pubsub/proto/ |
| D | pubsub_services.rb | 56 rpc :CreateSubscription, Subscription, Subscription
57 rpc :GetSubscription, GetSubscriptionRequest, Subscription
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FlowAsFluxTest.kt | 83 private lateinit var subscription: Subscription in <lambda>()
85 override fun onSubscribe(s: Subscription) { in <lambda>()
120 private lateinit var subscription: Subscription in <lambda>()
122 override fun onSubscribe(s: Subscription) { in <lambda>()
|
| /external/libcups/conf/ |
| D | cupsd.conf.in | 62 …start-Job Purge-Jobs Set-Job-Attributes Create-Job-Subscription Renew-Subscription Cancel-Subscrip…
106 …start-Job Purge-Jobs Set-Job-Attributes Create-Job-Subscription Renew-Subscription Cancel-Subscrip…
152 …start-Job Purge-Jobs Set-Job-Attributes Create-Job-Subscription Renew-Subscription Cancel-Subscrip…
|
| /external/libcups/test/ |
| D | 4.4-subscription-ops.test | 12 NAME "Add Printer Subscription w/Lease"
15 OPERATION Create-Printer-Subscription
41 NAME "Verify Subscription Expiration"
47 OPERATION Get-Subscription-Attributes
70 OPERATION Create-Printer-Subscription
132 OPERATION Create-Printer-Subscription
|
| /external/llvm-project/clang-tools-extra/clangd/unittests/support/ |
| D | FunctionTests.cpp | 21 Event<int>::Subscription SubA; in TEST()
26 Event<int>::Subscription SubB = E.observe([&](int) { ++N; }); in TEST()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Await.kt | 12 import org.reactivestreams.Subscription in <lambda>()
138 private lateinit var subscription: Subscription in awaitOne()
142 override fun onSubscribe(sub: Subscription) { in awaitOne()
|
| D | Channel.kt | 56 private val _subscription = atomic<Subscription?>(null) in consumeEach()
91 override fun onSubscribe(s: Subscription) { in consumeEach()
|
| D | ReactiveFlow.kt | 121 private lateinit var subscription: Subscription
142 override fun onSubscribe(s: Subscription) { in onSubscribe()
187 ) : Subscription, AbstractCoroutine<Unit>(context, true) {
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableSplit.java | 18 import org.reactivestreams.Subscription;
50 implements ConditionalSubscriber<String>, Subscription {
68 Subscription upstream;
114 public void onSubscribe(Subscription s) { in onSubscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-trace.hpp | 78 template<class SubscriptionState, class Subscription>
79 inline void subscription_add_enter(const SubscriptionState&, const Subscription&) {} in subscription_add_enter()
|