reactor.core.util.Exceptions$UpstreamException: java.lang.IllegalStateException: Queue is full?!

GitHub | evacchi | 11 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    dispatchOn raises exception when prefetch=1

    GitHub | 11 months ago | evacchi
    reactor.core.util.Exceptions$UpstreamException: java.lang.IllegalStateException: Queue is full?!

    Root Cause Analysis

    1. java.lang.IllegalStateException

      Queue is full?!

      at reactor.core.publisher.FluxDispatchOn$DispatchOnSubscriber.onNext()
    2. reactor.core.publisher
      TopicProcessor$TopicSubscriberLoop.run
      1. reactor.core.publisher.FluxDispatchOn$DispatchOnSubscriber.onNext(FluxDispatchOn.java:259)
      2. reactor.core.publisher.FluxLatest$LatestSubscriber.drain(FluxLatest.java:177)
      3. reactor.core.publisher.FluxLatest$LatestSubscriber.request(FluxLatest.java:97)
      4. reactor.core.publisher.FluxDispatchOn$DispatchOnSubscriber.runAsync(FluxDispatchOn.java:432)
      5. reactor.core.publisher.FluxDispatchOn$DispatchOnSubscriber.run(FluxDispatchOn.java:476)
      6. reactor.core.publisher.SchedulerGroup$TaskSubscriber.onNext(SchedulerGroup.java:1081)
      7. reactor.core.publisher.SchedulerGroup$TaskSubscriber.onNext(SchedulerGroup.java:1063)
      8. reactor.core.publisher.TopicProcessor$TopicSubscriberLoop.run(TopicProcessor.java:877)
      8 frames
    3. Java RT
      Thread.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      3. java.lang.Thread.run(Thread.java:745)
      3 frames