Closed
Description
See
rx.internal.operators.OperatorTakeLast
rx.internal.operators.TakeLastQueueProducer
What if there is OperatorTakeLast.onCompleted
has already started emit loop and there is TakeLastQueueProducer.request(n)
trying to run this loop as well. Shouldn't it cause concurrent access to ArrayDeque.poll/clear
?