NotificationTask(final ListenerKey<L> listenerKey, final Iterator<N> notifications) {
this.listenerKey = requireNonNull(listenerKey);
while (notifications.hasNext()) {
- queue.offer(notifications.next());
+ queue.add(notifications.next());
}
}
return true;
}
- queue.offer(notifications.next());
+ queue.add(notifications.next());
}
}
} finally {