java.lang.RuntimeException: rx.exceptions.MissingBackpressureException

GitHub | mcenkar | 5 months ago
  1. 0

    MissingBackpressureException when using Publishers

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

    Sporadic crash when trying to navigate to a waypoint

    GitHub | 2 years ago | Lineflyer
    java.lang.IllegalStateException: Exception thrown on Scheduler.Worker thread. Add `onError` handling.
  3. 0

    Caused by: rx.exceptions.MissingBackpressureException

    GitHub | 9 months ago | itxuye
    rx.exceptions.OnErrorNotImplementedException
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Zip$InnerSubscriber does not respect backpressure on RxRingBuffer

    GitHub | 1 year ago | stealthcode
    java.lang.RuntimeException: rx.exceptions.MissingBackpressureException
  6. 0

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

    Stack Overflow | 1 year ago | wujek
    rx.exceptions.MissingBackpressureException

    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