aboutsummaryrefslogtreecommitdiff
path: root/guava/src/com/google/common/eventbus/Dispatcher.java
diff options
context:
space:
mode:
Diffstat (limited to 'guava/src/com/google/common/eventbus/Dispatcher.java')
-rw-r--r--guava/src/com/google/common/eventbus/Dispatcher.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/guava/src/com/google/common/eventbus/Dispatcher.java b/guava/src/com/google/common/eventbus/Dispatcher.java
index 412bb789e..44f7c46ba 100644
--- a/guava/src/com/google/common/eventbus/Dispatcher.java
+++ b/guava/src/com/google/common/eventbus/Dispatcher.java
@@ -15,6 +15,7 @@
package com.google.common.eventbus;
import static com.google.common.base.Preconditions.checkNotNull;
+import static java.util.Objects.requireNonNull;
import com.google.common.collect.Queues;
import java.util.Iterator;
@@ -97,7 +98,8 @@ abstract class Dispatcher {
void dispatch(Object event, Iterator<Subscriber> subscribers) {
checkNotNull(event);
checkNotNull(subscribers);
- Queue<Event> queueForThread = queue.get();
+ // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get
+ Queue<Event> queueForThread = requireNonNull(queue.get());
queueForThread.offer(new Event(event, subscribers));
if (!dispatching.get()) {