I found that the LinkedBlockingQueue fills up to whatever the limit is set to, say 100 in this example and then it throws a buffer overflow exception which is gracefully swallowed. Be nice if you could pop off the queue once you've consumed an element from the stream.
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...
For further actions, you may consider blocking this person and/or reporting abuse
We're a place where coders share, stay up-to-date and grow their careers.
I found that the
LinkedBlockingQueuefills up to whatever the limit is set to, say 100 in this example and then it throws a buffer overflow exception which is gracefully swallowed. Be nice if you could pop off the queue once you've consumed an element from the stream.Not sure what you mean by poppin off the queue once the element's been consumed...
queue.take()is called insidetryAdvance, which removes the first element from the queue and passes it to the stream's consumer...