| /external/wpa_supplicant_8/src/wps/ |
| D | wps_upnp_i.h | 79 struct subscription { struct
82 time_t timeout_time; /* when to age out the subscription */ argument
85 * This uuid identifies the subscription and is randomly generated by argument
89 u8 uuid[UUID_LEN];
91 struct dl_list addr_list;
92 struct dl_list event_queue; /* Queued event messages. */
93 struct wps_event_ *current_event; /* non-NULL if being sent (not in q)
95 int last_event_failed; /* Whether delivery of last event failed */
98 u8 selected_registrar;
99 u16 dev_password_id;
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | FlowAsPublisherTest.kt | 26 private lateinit var subscription: Subscription in <lambda>() variable
56 private lateinit var subscription: Subscription in <lambda>() variable
87 private lateinit var subscription: Subscription in <lambda>() variable
124 private lateinit var subscription: Subscription in <lambda>() variable
|
| D | PublisherRequestStressTest.kt | 61 private lateinit var subscription: Subscription in <lambda>() variable in kotlinx.coroutines.reactive.PublisherRequestStressTest
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscription.hpp | 67 class subscription : public subscription_base class
113 subscription(weak_state_type w) in subscription() function in rxcpp::subscription
121 explicit subscription(std::shared_ptr<base_subscription_state> s) in subscription() function in rxcpp::subscription
130 subscription() in subscription() function in rxcpp::subscription
138 …explicit subscription(U u, typename std::enable_if<!is_subscription<U>::value, void**>::type = nul… in subscription() function in rxcpp::subscription
146 …explicit subscription(U u, typename std::enable_if<!std::is_same<subscription, U>::value && is_sub… in subscription() argument
154 subscription(const subscription& o) in subscription() function in rxcpp::subscription
161 subscription(subscription&& o) in subscription() function in rxcpp::subscription
|
| D | rx-notification.hpp | 14 class subscription class
20 explicit inline subscription(long s) in subscription() function in rxcpp::notifications::subscription
23 inline subscription(long s, long u) in subscription() function in rxcpp::notifications::subscription
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | FlowAsPublisherTest.kt | 26 private lateinit var subscription: JFlow.Subscription in testErrorOnCancellationIsReported() variable
56 private lateinit var subscription: JFlow.Subscription in testCancellationIsNotReported() variable
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 24 auto subscription = rxcpp::composite_subscription(); variable
49 auto subscription = rxcpp::composite_subscription(); variable
|
| D | subscribe.cpp | 62 auto subscription = rxcpp::composite_subscription(); variable
96 auto subscription = values.subscribe( variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Channel.kt | 66 val subscription = _subscription.value in consumeEach() constant
|
| D | Await.kt | 138 private lateinit var subscription: Subscription in awaitOne() variable
|
| D | ReactiveFlow.kt | 121 private lateinit var subscription: Subscription variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowAsFlowableTest.kt | 24 private lateinit var subscription: Subscription in <lambda>() variable
61 private lateinit var subscription: Subscription in <lambda>() variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowAsFlowableTest.kt | 24 private lateinit var subscription: Subscription in <lambda>() variable
61 private lateinit var subscription: Subscription in <lambda>() variable
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/ |
| D | main.cpp | 29 auto subscription = published_observable.connect(); in main() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Broadcast.kt | 178 val subscription = _channel.openSubscription() in openSubscription() constant
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/ |
| D | StatefulAwaitsBenchmark.kt | 104 val subscription = channel.openSubscription() in launchJob() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FlowAsFluxTest.kt | 83 private lateinit var subscription: Subscription in <lambda>() variable
120 private lateinit var subscription: Subscription in <lambda>() variable
|
| /external/openscreen/platform/impl/ |
| D | socket_handle_waiter.h | 94 SocketSubscription* subscription; member
|
| /external/pigweed/pw_web_ui/src/transport/ |
| D | web_serial_transport.ts | 88 for (const subscription of this.rxSubscriptions) { constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ArrayBroadcastChannelTest.kt | 197 val subscription = channel.openSubscription() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxAwait.kt | 169 private lateinit var subscription: Disposable in toString() variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxAwait.kt | 169 private lateinit var subscription: Disposable in toString() variable
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/base/ |
| D | base.py | 280 subscription, argument
|
| /external/openscreen/cast/sender/ |
| D | cast_app_discovery_service_impl_unittest.cc | 64 auto subscription = StartObservingAvailability(source_a_1_, receivers); in StartSourceA1Query() local
|
| /external/libchrome/base/ |
| D | callback_list_unittest.cc | 312 std::unique_ptr<CallbackList<void(void)>::Subscription> subscription = in TEST() local
|