Stream API и очереди: подписка на потоковый стиль BlockingQueue ⇐ JAVA

[Anonymous]

Предположим, у нас есть очередь

BlockingQueue queue= new LinkedBlockingQueue();


и какой-то другой поток помещает в него значения, затем мы читаем его как

while (true) {
String next = queue.take();
System.out.println("next message:" + next);
}


Как я могу перебирать эту очередь в потоковом стиле, сохраняя при этом семантику, аналогичную приведенному выше коду.

Это код проходит только текущее состояние очереди:

queue.stream().forEach(e -> System.out.println(e));


Подробнее здесь: https://stackoverflow.com/questions/234 ... ream-style