Скажем, у нас есть Очередь
BlockingQueue<String> queue= new LinkedBlockingQueue<>();
и какой-то другой поток помещает в него значения, тогда мы читаем его как
while (true) {
String next = queue.take();
System.out.println("next message:" + next);
}
Как я могу перебирать эту очередь в стиле потока, сохраняя при этом подобную семантику выше кода.
Этот код проходит только текущее состояние очереди:
queue.stream().forEach(e -> System.out.println(e));