| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 70 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch() argument
96 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch() argument
98 checkNotNull(subscribers); in dispatch()
100 queueForThread.offer(new Event(event, subscribers)); in dispatch()
107 while (nextEvent.subscribers.hasNext()) { in dispatch()
108 nextEvent.subscribers.next().dispatchEvent(nextEvent.event); in dispatch()
120 private final Iterator<Subscriber> subscribers; field in Dispatcher.PerThreadQueuedDispatcher.Event
122 private Event(Object event, Iterator<Subscriber> subscribers) { in Event() argument
124 this.subscribers = subscribers; in Event()
155 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch() argument
[all …]
|
| D | EventBus.java | 104 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
186 subscribers.register(object); in register()
196 subscribers.unregister(object); in unregister()
210 Iterator<Subscriber> eventSubscribers = subscribers.getSubscribers(event); in post()
|
| D | SubscriberRegistry.java | 64 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
82 CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); in register()
87 MoreObjects.firstNonNull(subscribers.putIfAbsent(eventType, newSet), newSet); in register()
102 CopyOnWriteArraySet<Subscriber> currentSubscribers = subscribers.get(eventType); in unregister()
119 return MoreObjects.firstNonNull(subscribers.get(eventType), ImmutableSet.<Subscriber>of()); in getSubscribersForTesting()
133 CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); in getSubscribers()
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 70 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch() argument
96 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch() argument
98 checkNotNull(subscribers); in dispatch()
100 queueForThread.offer(new Event(event, subscribers)); in dispatch()
107 while (nextEvent.subscribers.hasNext()) { in dispatch()
108 nextEvent.subscribers.next().dispatchEvent(nextEvent.event); in dispatch()
120 private final Iterator<Subscriber> subscribers; field in Dispatcher.PerThreadQueuedDispatcher.Event
122 private Event(Object event, Iterator<Subscriber> subscribers) { in Event() argument
124 this.subscribers = subscribers; in Event()
155 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch() argument
[all …]
|
| D | EventBus.java | 104 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
186 subscribers.register(object); in register()
196 subscribers.unregister(object); in unregister()
210 Iterator<Subscriber> eventSubscribers = subscribers.getSubscribers(event); in post()
|
| D | SubscriberRegistry.java | 64 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
82 CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); in register()
87 MoreObjects.firstNonNull(subscribers.putIfAbsent(eventType, newSet), newSet); in register()
102 CopyOnWriteArraySet<Subscriber> currentSubscribers = subscribers.get(eventType); in unregister()
119 return MoreObjects.firstNonNull(subscribers.get(eventType), ImmutableSet.<Subscriber>of()); in getSubscribersForTesting()
133 CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); in getSubscribers()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | SharingStressTest.kt | 99 val subscribers = ArrayList<SubJob>() in <lambda>() constant
105 … subscribers += launchSubscriber(sharedFlow, usingStateFlow, subCount, missingCollects) in <lambda>()
119 subscribers.forEach { in <lambda>()
123 subscribers.clear() in <lambda>()
128 if (!subscribers.isEmpty()) { in <lambda>()
130 subscribers.forEach { it.job.cancelAndJoin() } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ArrayBroadcastChannel.kt | 63 private val subscribers = subscriberList<Subscriber<E>>() constant in kotlinx.coroutines.channels.ArrayBroadcastChannel
89 for (sub in subscribers) sub.cancelInternal(cause) in cancelInternal()
134 for (sub in subscribers) { in checkSubOffers()
149 val wasEmpty = subscribers.isEmpty() in updateHead()
150 subscribers.add(addSub) in updateHead()
154 subscribers.remove(removeSub) in updateHead()
200 for (sub in subscribers) in computeMinHead()
|
| D | ConflatedBroadcastChannel.kt | 57 @JvmField val subscribers: Array<Subscriber<E>>? in <lambda>() constant in kotlinx.coroutines.channels.ConflatedBroadcastChannel.State
111 … val update = State(state.value, addSubscriber((state as State<E>).subscribers, subscriber)) in <lambda>()
126 … val update = State(state.value, removeSubscriber((state as State<E>).subscribers!!, subscriber)) in <lambda>()
167 (state as State<E>).subscribers?.forEach { it.close(cause) } in <lambda>()
250 val update = State(element, (state as State<E>).subscribers) in <lambda>()
255 state.subscribers?.forEach { it.offerInternal(element) } in <lambda>()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-ref_count.hpp | 103 , subscribers(0) in ref_count_state()
112 , subscribers(0) in ref_count_state()
117 long subscribers; member
149 auto needConnect = ++state->subscribers == 1; in on_subscribe()
155 if (--keepAlive->subscribers == 0) { in on_subscribe()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | ShareInTest.kt | 132 suspend fun checkStartTransition(subscribers: Int) { in <lambda>()
133 when (subscribers) { in <lambda>()
145 suspend fun checkStopTransition(subscribers: Int) { in <lambda>()
146 when (subscribers) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/ |
| D | package.list | 14 io.reactivex.subscribers
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/ |
| D | package.list | 14 io.reactivex.rxjava3.subscribers
|
| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-broker/ |
| D | README.md | 26 sent to all subscribers.
|
| /external/Reactive-Extensions/RxCpp/ |
| D | DeveloperManual.md | 17 ```coordinator``` has a ```worker```, and is a factory for coordinated observables, subscribers and…
|
| /external/curl/docs/ |
| D | MAIL-ETIQUETTE | 71 through to all the subscribers.
83 subscribers be moderated. This means that after you've subscribed and
258 We allow subscribers to subscribe to the "digest" version of the mailing
|
| D | FAQ | 375 the curl-library mailing list. We're many subscribers there and there are
|
| /external/python/cpython2/Misc/ |
| D | RFD | 82 Currently there is a mailing list with over 130 subscribers.
|
| /external/toybox/ |
| D | README | 161 Then send a file attachment. The list holds messages from non-subscribers
|
| /external/freetype/docs/ |
| D | formats.txt | 69 subscribers only). If you can provide a font example for a format
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 27 * Fix `SharedFlow` with replay for subscribers working at different speed (#2325).
1007 be received by multiple subscribers without any omissions.
|
| /external/libevent/ |
| D | whatsnew-2.1.txt | 32 is subscribers-only, so you will need to subscribe before you post.
|
| /external/cldr/tools/java/org/unicode/cldr/util/data/ |
| D | europe | 1847 # in Latvian for subscribers only).
|
| /external/libtextclassifier/native/annotator/pod_ner/test_data/ |
| D | vocab.txt | 17074 subscribers
|
| /external/rust/crates/libz-sys/src/zlib-ng/test/data/ |
| D | lcet10.txt | 2147 typeset-quality screens; and Hypertext links that enable subscribers to
2204 maintained on the computer permanently and subscribers, as part of
|