Searched refs:mMessageConsumers (Results 1 – 1 of 1) sorted by relevance
57 private final Map<Object, MessageConsumer> mMessageConsumers = new ArrayMap<>(); field in RemoteIo83 synchronized (mMessageConsumers) { in addMessageConsumer()84 mMessageConsumers.put(consumer, new MessageConsumer(consumer)); in addMessageConsumer()90 synchronized (mMessageConsumers) { in removeMessageConsumer()91 if (mMessageConsumers.remove(consumer) == null) { in removeMessageConsumer()136 synchronized (mMessageConsumers) { in run()137 mMessageConsumers.values().forEach(consumer -> consumer.accept(event)); in run()