DEV Community

Discussion on: Streaming large queries in Java

Collapse
 
chochos profile image
Enrique Zamudio

Not sure what you mean by poppin off the queue once the element's been consumed... queue.take() is called inside tryAdvance, which removes the first element from the queue and passes it to the stream's consumer...