java.lang.RuntimeException: rx.exceptions.MissingBackpressureException

GitHub | mcenkar | 6 months ago
  1. 0

    MissingBackpressureException when using Publishers

    GitHub | 6 months ago | mcenkar
    java.lang.RuntimeException: rx.exceptions.MissingBackpressureException
  2. 0

    `onBackpressureDrop()` used and still `MissingBackpressureException` thrown

    Stack Overflow | 2 years ago | wujek
    rx.exceptions.MissingBackpressureException
  3. 0

    RxJava- MissingBackpressureException on my Operator?

    Stack Overflow | 11 months ago | Thomas N.
    rx.exceptions.MissingBackpressureException
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 5#61395263

    GitHub | 2 years ago | benjchristensen
    rx.exceptions.MissingBackpressureException
  6. 0

    Crash on subscribe

    GitHub | 12 months ago | shahimclt
    java.lang.IllegalStateException: Exception thrown on Scheduler.Worker thread. Add `onError` handling.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. rx.exceptions.MissingBackpressureException

      No message provided

      at rx.internal.util.RxRingBuffer.onNext()
    2. rxjava
      OperatorMerge$InnerSubscriber.onNext
      1. rx.internal.util.RxRingBuffer.onNext(RxRingBuffer.java:352)
      2. rx.internal.operators.OperatorMerge$MergeSubscriber.queueScalar(OperatorMerge.java:346)
      3. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:329)
      4. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:804)
      4 frames
    3. rx.internal.reactivestreams
      PublisherAdapter$1.onNext
      1. rx.internal.reactivestreams.SubscriberAdapter.onNext(SubscriberAdapter.java:52)
      2. rx.internal.reactivestreams.PublisherAdapter$1.onNext(PublisherAdapter.java:107)
      2 frames
    4. rxjava
      Observable.subscribe
      1. rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:139)
      2. rx.internal.operators.OperatorSerialize$1.onNext(OperatorSerialize.java:52)
      3. rx.observers.SerializedObserver.onNext(SerializedObserver.java:95)
      4. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:95)
      5. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:97)
      6. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:73)
      7. rx.Subscriber.setProducer(Subscriber.java:211)
      8. rx.Subscriber.setProducer(Subscriber.java:205)
      9. rx.Subscriber.setProducer(Subscriber.java:205)
      10. rx.Subscriber.setProducer(Subscriber.java:205)
      11. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:49)
      12. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:32)
      13. rx.Observable$2.call(Observable.java:162)
      14. rx.Observable$2.call(Observable.java:154)
      15. rx.Observable.subscribe(Observable.java:8265)
      16. rx.Observable.subscribe(Observable.java:8232)
      16 frames
    5. rx.internal.reactivestreams
      PublisherAdapter.subscribe
      1. rx.internal.reactivestreams.PublisherAdapter.subscribe(PublisherAdapter.java:43)
      1 frame
    6. rxjava
      BlockingObservable$2.iterator
      1. rx.RxReactiveStreams$1.call(RxReactiveStreams.java:58)
      2. rx.RxReactiveStreams$1.call(RxReactiveStreams.java:55)
      3. rx.Observable.unsafeSubscribe(Observable.java:8172)
      4. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:232)
      5. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:142)
      6. rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:54)
      7. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.fastpath(OnSubscribeFromIterable.java:127)
      8. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:70)
      9. rx.Subscriber.setProducer(Subscriber.java:211)
      10. rx.Subscriber.setProducer(Subscriber.java:205)
      11. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:49)
      12. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:32)
      13. rx.Observable$2.call(Observable.java:162)
      14. rx.Observable$2.call(Observable.java:154)
      15. rx.Observable$2.call(Observable.java:162)
      16. rx.Observable$2.call(Observable.java:154)
      17. rx.Observable$2.call(Observable.java:162)
      18. rx.Observable$2.call(Observable.java:154)
      19. rx.Observable.subscribe(Observable.java:8265)
      20. rx.Observable.subscribe(Observable.java:8232)
      21. rx.internal.operators.BlockingOperatorToIterator.toIterator(BlockingOperatorToIterator.java:53)
      22. rx.observables.BlockingObservable.getIterator(BlockingObservable.java:147)
      23. rx.observables.BlockingObservable$2.iterator(BlockingObservable.java:416)
      23 frames
    7. Scala
      AbstractTraversable.toList
      1. scala.collection.convert.Wrappers$JIterableWrapper.iterator(Wrappers.scala:54)
      2. scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
      3. scala.collection.AbstractIterable.foreach(Iterable.scala:54)
      4. scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:59)
      5. scala.collection.mutable.ListBuffer.$plus$plus$eq(ListBuffer.scala:183)
      6. scala.collection.mutable.ListBuffer.$plus$plus$eq(ListBuffer.scala:45)
      7. scala.collection.TraversableLike$class.to(TraversableLike.scala:590)
      8. scala.collection.AbstractTraversable.to(Traversable.scala:104)
      9. scala.collection.TraversableOnce$class.toList(TraversableOnce.scala:294)
      10. scala.collection.AbstractTraversable.toList(Traversable.scala:104)
      10 frames
    8. rxscala
      BlockingObservable$.toList$extension
      1. rx.lang.scala.observables.BlockingObservable$.toList$extension(BlockingObservable.scala:232)
      1 frame
    9. com.leonteq.website
      Test$delayedInit$body.apply
      1. com.leonteq.website.feed.server.service.timeseries.Test$.delayedEndpoint$com$leonteq$website$feed$server$service$timeseries$Test$1(Test.scala:18)
      2. com.leonteq.website.feed.server.service.timeseries.Test$delayedInit$body.apply(Test.scala:9)
      2 frames
    10. Scala
      App$class.main
      1. scala.Function0$class.apply$mcV$sp(Function0.scala:34)
      2. scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
      3. scala.App$$anonfun$main$1.apply(App.scala:76)
      4. scala.App$$anonfun$main$1.apply(App.scala:76)
      5. scala.collection.immutable.List.foreach(List.scala:381)
      6. scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
      7. scala.App$class.main(App.scala:76)
      7 frames
    11. com.leonteq.website
      Test.main
      1. com.leonteq.website.feed.server.service.timeseries.Test$.main(Test.scala:9)
      2. com.leonteq.website.feed.server.service.timeseries.Test.main(Test.scala)
      2 frames
    12. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:497)
      4 frames
    13. IDEA
      AppMain.main
      1. com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
      1 frame