java.lang.NullPointerException

GitHub | thomasnield | 2 months ago
  1. 0

    Android: Saving Map State in Google map

    Stack Overflow | 11 months ago | Junie Negentien
    java.lang.RuntimeException: Unable to resume activity {com.ourThesis.junieNegentien2015/com.ourThesis.junieNegentien2015.MainActivity}: java.lang.NullPointerException
  2. Speed up your debug routine!

    Automated exception search integrated into your IDE

    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. java.lang.NullPointerException

      No message provided

      at com.github.davidmoten.rx.jdbc.ConnectionProviderBatch.close()
    2. com.github.davidmoten
      QueryUpdateOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.ConnectionProviderBatch.close(ConnectionProviderBatch.java:24)
      2. com.github.davidmoten.rx.jdbc.Database.endTransactionObserve(Database.java:687)
      3. com.github.davidmoten.rx.jdbc.QueryContext.endTransactionObserve(QueryContext.java:57)
      4. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:91)
      5. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)
      5 frames
    3. rxjava
      OnSubscribeConcatMap$ConcatMapSubscriber.onNext
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      9 frames
    4. com.github.davidmoten
      OnSubscribeMapLast$MapLastSubscriber.onCompleted
      1. com.github.davidmoten.rx.internal.operators.OnSubscribeMapLast$MapLastSubscriber.onCompleted(OnSubscribeMapLast.java:79)
      1 frame
    5. rxjava
      Observable.unsafeSubscribe
      1. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      2. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      3. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      4. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      6. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)
      7. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      8. rx.Subscriber.setProducer(Subscriber.java:211)
      9. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      10. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      11. rx.Observable.unsafeSubscribe(Observable.java:10211)
      12. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      14. rx.Observable.unsafeSubscribe(Observable.java:10211)
      15. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      16. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      17. rx.Observable.unsafeSubscribe(Observable.java:10211)
      17 frames
    6. com.github.davidmoten
      OnSubscribeMapLast.call
      1. com.github.davidmoten.rx.internal.operators.OnSubscribeMapLast.call(OnSubscribeMapLast.java:33)
      2. com.github.davidmoten.rx.internal.operators.OnSubscribeMapLast.call(OnSubscribeMapLast.java:13)
      2 frames
    7. rxjava
      OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      3. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      4. rx.Observable.unsafeSubscribe(Observable.java:10211)
      5. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      6. rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:40)
      7. rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:24)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      10. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      11. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      12. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      13. rx.Observable.unsafeSubscribe(Observable.java:10211)
      14. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      15. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      16. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      17. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      18. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      19. rx.internal.operators.DeferredScalarSubscriber.complete(DeferredScalarSubscriber.java:100)
      20. rx.internal.operators.DeferredScalarSubscriber.onCompleted(DeferredScalarSubscriber.java:73)
      21. rx.internal.operators.DeferredScalarSubscriberSafe.onCompleted(DeferredScalarSubscriberSafe.java:54)
      22. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      23. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      24. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      25. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      26. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      27. rx.internal.operators.OperatorBufferWithSize$BufferExact.onCompleted(OperatorBufferWithSize.java:130)
      28. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      29. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      30. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      31. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      32. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      33. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      34. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      35. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      36. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)
      37. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      38. rx.Subscriber.setProducer(Subscriber.java:211)
      39. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      40. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      41. rx.Observable.unsafeSubscribe(Observable.java:10211)
      42. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      43. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      44. rx.Observable.unsafeSubscribe(Observable.java:10211)
      45. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      46. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      47. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      48. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      49. rx.Observable.unsafeSubscribe(Observable.java:10211)
      50. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      51. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      52. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      53. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      54. rx.Observable.unsafeSubscribe(Observable.java:10211)
      55. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      56. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:50)
      57. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:24)
      58. rx.Observable.unsafeSubscribe(Observable.java:10211)
      59. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      60. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      61. rx.Observable.unsafeSubscribe(Observable.java:10211)
      62. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      63. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      64. rx.Observable.unsafeSubscribe(Observable.java:10211)
      65. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      66. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      67. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      68. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      69. rx.Observable.unsafeSubscribe(Observable.java:10211)
      70. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:235)
      71. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:228)
      72. rx.Observable.unsafeSubscribe(Observable.java:10211)
      73. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      74. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      75. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      76. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      77. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      78. rx.internal.operators.DeferredScalarSubscriber.complete(DeferredScalarSubscriber.java:100)
      79. rx.internal.operators.DeferredScalarSubscriber.onCompleted(DeferredScalarSubscriber.java:73)
      80. rx.internal.operators.DeferredScalarSubscriberSafe.onCompleted(DeferredScalarSubscriberSafe.java:54)
      81. rx.internal.operators.OnSubscribeRedo$4$1.onCompleted(OnSubscribeRedo.java:321)
      82. rx.internal.operators.OperatorDematerialize$1.onCompleted(OperatorDematerialize.java:85)
      83. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      84. rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:298)
      85. rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:284)
      86. rx.internal.operators.NotificationLite.accept(NotificationLite.java:152)
      87. rx.subjects.SubjectSubscriptionManager$SubjectObserver.emitNext(SubjectSubscriptionManager.java:255)
      88. rx.subjects.BehaviorSubject.onNext(BehaviorSubject.java:162)
      89. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      90. rx.subjects.SerializedSubject.onNext(SerializedSubject.java:67)
      91. rx.internal.operators.OnSubscribeRedo$2$1.onCompleted(OnSubscribeRedo.java:228)
      92. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)
      92 frames
    8. com.swa.rm
      OperatorEmissionCounter$call$parent$1.onCompleted
      1. com.swa.rm.common.util.OperatorEmissionCounter$call$parent$1.onCompleted(RxOperators.kt:210)
      1 frame
    9. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      2. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      3. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      4. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      6. rx.internal.operators.OperatorBufferWithSize$BufferExact.onCompleted(OperatorBufferWithSize.java:130)
      7. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      8. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      11. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      12. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      15. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)
      16. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      17. rx.Subscriber.setProducer(Subscriber.java:211)
      18. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      19. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      20. rx.Observable.unsafeSubscribe(Observable.java:10211)
      21. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      22. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      23. rx.Observable.unsafeSubscribe(Observable.java:10211)
      24. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      25. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      26. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      27. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      28. rx.Observable.unsafeSubscribe(Observable.java:10211)
      29. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      30. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      31. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      32. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      33. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      34. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      35. rx.Observable.unsafeSubscribe(Observable.java:10211)
      36. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      37. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      38. rx.Observable.unsafeSubscribe(Observable.java:10211)
      39. rx.internal.operators.OnSubscribeRedo$2.call(OnSubscribeRedo.java:273)
      40. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      41. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      42. rx.internal.operators.OnSubscribeRedo$5.request(OnSubscribeRedo.java:361)
      43. rx.internal.operators.DeferredScalarSubscriber.setProducer(DeferredScalarSubscriber.java:143)
      44. rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:353)
      45. rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:47)
      46. rx.Observable.unsafeSubscribe(Observable.java:10211)
      47. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      48. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:50)
      49. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:24)
      50. rx.Observable.unsafeSubscribe(Observable.java:10211)
      51. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      52. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      53. rx.Observable.unsafeSubscribe(Observable.java:10211)
      54. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      55. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      56. rx.Observable.unsafeSubscribe(Observable.java:10211)
      57. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      58. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      59. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      60. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      61. rx.Observable.unsafeSubscribe(Observable.java:10211)
      62. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:235)
      63. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:228)
      64. rx.Observable.unsafeSubscribe(Observable.java:10211)
      65. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      66. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      67. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      68. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      69. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      70. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      71. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      72. rx.observers.Subscribers$5.onNext(Subscribers.java:235)
      73. rx.internal.operators.OperatorDistinct$1.onNext(OperatorDistinct.java:63)
      74. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      75. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      76. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      77. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      78. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      79. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      80. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      81. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      82. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      82 frames
    10. com.github.davidmoten
      QuerySelectProducer.request
      1. com.github.davidmoten.rx.jdbc.QuerySelectProducer.processRow(QuerySelectProducer.java:115)
      2. com.github.davidmoten.rx.jdbc.QuerySelectProducer.requestSome(QuerySelectProducer.java:76)
      3. com.github.davidmoten.rx.jdbc.QuerySelectProducer.request(QuerySelectProducer.java:48)
      3 frames
    11. rxjava
      OperatorSubscribeOn$1$1$1.request
      1. rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)
      1 frame
    12. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    13. rxjava
      OperatorSubscribeOn$1$1.setProducer
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)
      2 frames
    14. com.github.davidmoten
      QuerySelectOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:69)
      2. com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:20)
      2 frames
    15. rxjava
      OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      10. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request(OnSubscribeConcatMap.java:366)
      14 frames
    16. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    17. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:278)
      2. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      3. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      4. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      5. rx.Subscriber.setProducer(Subscriber.java:211)
      6. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      7. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      10. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      11. rx.Observable.unsafeSubscribe(Observable.java:10211)
      12. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      13. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      14. rx.Observable.unsafeSubscribe(Observable.java:10211)
      15. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      16. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      17. rx.Observable.unsafeSubscribe(Observable.java:10211)
      18. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      19. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      20. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      21. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      22. rx.Subscriber.setProducer(Subscriber.java:211)
      23. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      24. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      25. rx.Observable.unsafeSubscribe(Observable.java:10211)
      26. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      27. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      28. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      29. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      30. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      31. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      32. rx.Observable.unsafeSubscribe(Observable.java:10211)
      33. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      34. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      35. rx.Observable.unsafeSubscribe(Observable.java:10211)
      36. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      37. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      38. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      39. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      40. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      41. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      42. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      43. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      44. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      45. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      46. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      47. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      47 frames
    18. com.github.davidmoten
      QueryUpdateOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.performUpdate(QueryUpdateOnSubscribe.java:259)
      2. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:88)
      3. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)
      3 frames
    19. rxjava
      OnSubscribeFromIterable$IterableProducer.request
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      10. rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      16. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      16 frames
    20. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    21. rxjava
      ScalarSynchronousObservable$WeakSingleProducer.request
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
      3. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
      4. rx.Observable.unsafeSubscribe(Observable.java:10211)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      6. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      7. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      8. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      16. rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)
      16 frames
    22. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    23. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
      3. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)
      4. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)
      5. rx.Observable.unsafeSubscribe(Observable.java:10211)
      6. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      7. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      11. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      12. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      13. rx.Subscriber.setProducer(Subscriber.java:211)
      14. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      15. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      16. rx.Observable.unsafeSubscribe(Observable.java:10211)
      17. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      18. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      19. rx.Observable.unsafeSubscribe(Observable.java:10211)
      20. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      21. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      22. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      23. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      24. rx.Subscriber.setProducer(Subscriber.java:211)
      25. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      26. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      27. rx.Observable.unsafeSubscribe(Observable.java:10211)
      28. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      29. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      30. rx.Observable.unsafeSubscribe(Observable.java:10211)
      31. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      32. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      33. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      34. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      35. rx.Observable.unsafeSubscribe(Observable.java:10211)
      36. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      37. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      38. rx.Observable.unsafeSubscribe(Observable.java:10211)
      39. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      40. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      41. rx.Observable.unsafeSubscribe(Observable.java:10211)
      42. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      43. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      44. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      45. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      46. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      47. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      48. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      49. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      49 frames
    24. com.github.davidmoten
      QueryUpdateOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.performUpdate(QueryUpdateOnSubscribe.java:259)
      2. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:88)
      3. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)
      3 frames
    25. rxjava
      OnSubscribeFromIterable$IterableProducer.request
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      10. rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      16. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      16 frames
    26. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    27. rxjava
      ScalarSynchronousObservable$WeakSingleProducer.request
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
      3. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
      4. rx.Observable.unsafeSubscribe(Observable.java:10211)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      6. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      7. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      8. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      16. rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)
      16 frames
    28. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    29. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
      3. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)
      4. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)
      5. rx.Observable.unsafeSubscribe(Observable.java:10211)
      6. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      7. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      11. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      12. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      13. rx.Subscriber.setProducer(Subscriber.java:211)
      14. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      15. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      16. rx.Observable.unsafeSubscribe(Observable.java:10211)
      17. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      18. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      19. rx.Observable.unsafeSubscribe(Observable.java:10211)
      20. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      21. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      22. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      23. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      24. rx.Subscriber.setProducer(Subscriber.java:211)
      25. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      26. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      27. rx.Observable.unsafeSubscribe(Observable.java:10211)
      28. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      29. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      30. rx.Observable.unsafeSubscribe(Observable.java:10211)
      31. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      32. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      33. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      34. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      35. rx.Observable.unsafeSubscribe(Observable.java:10211)
      36. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      37. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      38. rx.Observable.unsafeSubscribe(Observable.java:10211)
      39. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      40. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      41. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      42. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      43. rx.Observable.unsafeSubscribe(Observable.java:10211)
      44. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      45. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      46. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      47. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      48. rx.Observable.unsafeSubscribe(Observable.java:10211)
      49. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      50. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      51. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      52. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      53. rx.Observable.unsafeSubscribe(Observable.java:10211)
      54. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      55. rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:40)
      56. rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:24)
      57. rx.Observable.unsafeSubscribe(Observable.java:10211)
      58. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      59. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      60. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      61. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      62. rx.Observable.unsafeSubscribe(Observable.java:10211)
      63. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      64. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      65. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      66. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      67. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      68. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      69. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      70. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      70 frames
    30. com.github.davidmoten
      QueryUpdateOnSubscribe$2.onNext
      1. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe$2.onNext(QueryUpdateOnSubscribe.java:279)
      1 frame
    31. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      2. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      3. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      4. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      5. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      5 frames
    32. com.github.davidmoten
      QuerySelectProducer.request
      1. com.github.davidmoten.rx.jdbc.QuerySelectProducer.processRow(QuerySelectProducer.java:115)
      2. com.github.davidmoten.rx.jdbc.QuerySelectProducer.requestAll(QuerySelectProducer.java:56)
      3. com.github.davidmoten.rx.jdbc.QuerySelectProducer.request(QuerySelectProducer.java:46)
      3 frames
    33. rxjava
      OperatorSubscribeOn$1$1$1.request
      1. rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)
      1 frame
    34. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    35. rxjava
      OperatorSubscribeOn$1$1.setProducer
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)
      2 frames
    36. com.github.davidmoten
      QuerySelectOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:69)
      2. com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:20)
      2 frames
    37. rxjava
      OnSubscribeFromIterable$IterableProducer.request
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      10. rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      16. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      16 frames
    38. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    39. rxjava
      OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
      3. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
      4. rx.Observable.unsafeSubscribe(Observable.java:10211)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      6. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      7. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      8. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request(OnSubscribeConcatMap.java:366)
      10 frames
    40. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    41. rxjava
      Observable.unsafeSubscribe
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:278)
      2. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      3. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      4. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      5. rx.Subscriber.setProducer(Subscriber.java:211)
      6. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      7. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      10. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      11. rx.Observable.unsafeSubscribe(Observable.java:10211)
      12. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      14. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      15. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      16. rx.Observable.unsafeSubscribe(Observable.java:10211)
      17. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      18. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      19. rx.Observable.unsafeSubscribe(Observable.java:10211)
      19 frames
    42. com.github.davidmoten
      QueryUpdateOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.performUpdate(QueryUpdateOnSubscribe.java:247)
      2. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:88)
      3. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)
      3 frames
    43. rxjava
      OnSubscribeFromIterable$IterableProducer.request
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      10. rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      16. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      16 frames
    44. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    45. rxjava
      ScalarSynchronousObservable$WeakSingleProducer.request
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
      3. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
      4. rx.Observable.unsafeSubscribe(Observable.java:10211)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      6. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      7. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      8. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      16. rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)
      16 frames
    46. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    47. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
      3. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)
      4. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)
      5. rx.Observable.unsafeSubscribe(Observable.java:10211)
      6. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      7. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      11. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      12. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      13. rx.Subscriber.setProducer(Subscriber.java:211)
      14. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      15. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      16. rx.Observable.unsafeSubscribe(Observable.java:10211)
      17. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      18. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      19. rx.Observable.unsafeSubscribe(Observable.java:10211)
      20. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      21. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      22. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      23. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      24. rx.Subscriber.setProducer(Subscriber.java:211)
      25. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      26. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      27. rx.Observable.unsafeSubscribe(Observable.java:10211)
      28. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      29. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      30. rx.Observable.unsafeSubscribe(Observable.java:10211)
      31. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      32. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      33. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      34. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      35. rx.Observable.unsafeSubscribe(Observable.java:10211)
      36. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      37. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      38. rx.Observable.unsafeSubscribe(Observable.java:10211)
      39. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      40. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      41. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      42. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      43. rx.Observable.unsafeSubscribe(Observable.java:10211)
      44. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      45. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      46. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      47. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      48. rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)
      49. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      50. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      51. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      52. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      53. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      54. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      55. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      56. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      56 frames
    48. com.github.davidmoten
      QuerySelectProducer.request
      1. com.github.davidmoten.rx.jdbc.QuerySelectProducer.processRow(QuerySelectProducer.java:115)
      2. com.github.davidmoten.rx.jdbc.QuerySelectProducer.requestSome(QuerySelectProducer.java:76)
      3. com.github.davidmoten.rx.jdbc.QuerySelectProducer.request(QuerySelectProducer.java:48)
      3 frames
    49. rxjava
      OperatorSubscribeOn$1$1$1.request
      1. rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)
      1 frame
    50. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    51. rxjava
      OperatorSubscribeOn$1$1.setProducer
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)
      2 frames
    52. com.github.davidmoten
      QuerySelectOnSubscribe.call
      1. com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:69)
      2. com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:20)
      2 frames
    53. rxjava
      OnSubscribeFromIterable$IterableProducer.request
      1. rx.Observable.unsafeSubscribe(Observable.java:10211)
      2. rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
      3. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      4. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      5. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)
      6. rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)
      7. rx.Observable.unsafeSubscribe(Observable.java:10211)
      8. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      10. rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      16. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      16 frames
    54. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    55. rxjava
      ScalarSynchronousObservable$WeakSingleProducer.request
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
      3. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
      4. rx.Observable.unsafeSubscribe(Observable.java:10211)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      6. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      7. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      8. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      11. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      12. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      13. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      15. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      16. rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)
      16 frames
    56. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    57. rxjava
      ScheduledAction.run
      1. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)
      2. rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
      3. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)
      4. rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)
      5. rx.Observable.unsafeSubscribe(Observable.java:10211)
      6. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      7. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      8. rx.Observable.unsafeSubscribe(Observable.java:10211)
      9. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      11. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      12. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      13. rx.Subscriber.setProducer(Subscriber.java:211)
      14. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      15. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      16. rx.Observable.unsafeSubscribe(Observable.java:10211)
      17. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      18. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      19. rx.Observable.unsafeSubscribe(Observable.java:10211)
      20. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)
      21. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)
      22. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      23. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      24. rx.Subscriber.setProducer(Subscriber.java:211)
      25. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      26. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      27. rx.Observable.unsafeSubscribe(Observable.java:10211)
      28. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      29. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      30. rx.Observable.unsafeSubscribe(Observable.java:10211)
      31. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      32. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      33. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      34. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      35. rx.Observable.unsafeSubscribe(Observable.java:10211)
      36. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      37. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      38. rx.Observable.unsafeSubscribe(Observable.java:10211)
      39. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      40. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      41. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      42. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      43. rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)
      44. rx.internal.operators.OnSubscribeTimerPeriodically$1.call(OnSubscribeTimerPeriodically.java:52)
      45. rx.Scheduler$Worker$1.call(Scheduler.java:137)
      46. rx.internal.schedulers.CachedThreadScheduler$EventLoopWorker$1.call(CachedThreadScheduler.java:228)
      47. rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)
      47 frames
    58. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
      4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
      5. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      6. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      7. java.lang.Thread.run(Thread.java:745)
      7 frames