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.onNext
      1. com.github.davidmoten.rx.internal.operators.OnSubscribeMapLast$MapLastSubscriber.onNext(OnSubscribeMapLast.java:97)
      1 frame
    5. rxjava
      OnSubscribeFromIterable$IterableProducer.request
      1. rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)
      2. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      3. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      4. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      6. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      7. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      7 frames
    6. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    7. rxjava
      OnSubscribeMap$MapSubscriber.onNext
      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)
      15 frames
    8. com.github.davidmoten
      OperatorFromTransformer$ParentSubscriber.onNext
      1. com.github.davidmoten.rx.internal.operators.OperatorFromTransformer$ParentSubscriber.onNext(OperatorFromTransformer.java:93)
      1 frame
    9. rxjava
      OnSubscribeRedo$2$1.onCompleted
      1. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      2. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      3. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      4. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      5. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)
      6. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)
      7. rx.Subscriber.setProducer(Subscriber.java:211)
      8. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
      9. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
      10. rx.Observable.unsafeSubscribe(Observable.java:10211)
      11. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      12. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      13. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      14. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      15. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      16. rx.internal.operators.DeferredScalarSubscriber.complete(DeferredScalarSubscriber.java:100)
      17. rx.internal.operators.DeferredScalarSubscriber.onCompleted(DeferredScalarSubscriber.java:73)
      18. rx.internal.operators.DeferredScalarSubscriberSafe.onCompleted(DeferredScalarSubscriberSafe.java:54)
      19. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      20. rx.internal.operators.OnSubscribeRedo$4$1.onCompleted(OnSubscribeRedo.java:321)
      21. rx.internal.operators.OperatorDematerialize$1.onCompleted(OperatorDematerialize.java:85)
      22. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      23. rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:298)
      24. rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:284)
      25. rx.internal.operators.NotificationLite.accept(NotificationLite.java:152)
      26. rx.subjects.SubjectSubscriptionManager$SubjectObserver.emitNext(SubjectSubscriptionManager.java:255)
      27. rx.subjects.BehaviorSubject.onNext(BehaviorSubject.java:162)
      28. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      29. rx.subjects.SerializedSubject.onNext(SerializedSubject.java:67)
      30. rx.internal.operators.OnSubscribeRedo$2$1.onCompleted(OnSubscribeRedo.java:228)
      30 frames
    10. com.swa.rm
      OperatorEmissionCounter$call$parent$1.onCompleted
      1. com.swa.rm.common.util.OperatorEmissionCounter$call$parent$1.onCompleted(RxOperators.kt:210)
      2. com.swa.rm.common.util.OperatorEmissionCounter$call$parent$1.onCompleted(RxOperators.kt:210)
      2 frames
    11. rxjava
      OperatorSubscribeOn$1$1.onNext
      1. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)
      2. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      3. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      4. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      5. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      6. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      7. rx.internal.operators.OperatorBufferWithSize$BufferExact.onCompleted(OperatorBufferWithSize.java:130)
      8. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      9. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      10. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      11. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      12. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      13. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      14. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      15. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      16. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)
      17. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      18. rx.Subscriber.setProducer(Subscriber.java:211)
      19. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      20. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      21. rx.Observable.unsafeSubscribe(Observable.java:10211)
      22. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      23. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      24. rx.Observable.unsafeSubscribe(Observable.java:10211)
      25. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      26. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      27. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      28. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      29. rx.Observable.unsafeSubscribe(Observable.java:10211)
      30. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      31. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      32. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      33. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      34. rx.Observable.unsafeSubscribe(Observable.java:10211)
      35. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      36. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      37. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      38. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      39. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      40. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      41. rx.Observable.unsafeSubscribe(Observable.java:10211)
      42. rx.internal.operators.OnSubscribeRedo$2.call(OnSubscribeRedo.java:273)
      43. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
      44. rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
      45. rx.internal.operators.OnSubscribeRedo$5.request(OnSubscribeRedo.java:361)
      46. rx.internal.operators.DeferredScalarSubscriber.setProducer(DeferredScalarSubscriber.java:143)
      47. rx.Subscriber.setProducer(Subscriber.java:205)
      48. rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:353)
      49. rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:47)
      50. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      51. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      52. rx.Observable.unsafeSubscribe(Observable.java:10211)
      53. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      54. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:50)
      55. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:24)
      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.Observable.unsafeSubscribe(Observable.java:10211)
      60. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      61. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      62. rx.Observable.unsafeSubscribe(Observable.java:10211)
      63. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      64. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      65. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      66. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      67. rx.Observable.unsafeSubscribe(Observable.java:10211)
      68. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      69. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      70. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      71. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      72. rx.Observable.unsafeSubscribe(Observable.java:10211)
      73. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      74. rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:40)
      75. rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:24)
      76. rx.Observable.unsafeSubscribe(Observable.java:10211)
      77. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      78. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      79. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      80. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      81. rx.Observable.unsafeSubscribe(Observable.java:10211)
      82. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      83. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      84. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      85. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      86. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      87. rx.internal.operators.DeferredScalarSubscriber.complete(DeferredScalarSubscriber.java:100)
      88. rx.internal.operators.DeferredScalarSubscriber.onCompleted(DeferredScalarSubscriber.java:73)
      89. rx.internal.operators.DeferredScalarSubscriberSafe.onCompleted(DeferredScalarSubscriberSafe.java:54)
      90. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      91. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      92. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      93. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      94. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      95. rx.internal.operators.OperatorBufferWithSize$BufferExact.onCompleted(OperatorBufferWithSize.java:130)
      96. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      97. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      98. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      99. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      100. rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)
      101. rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)
      102. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)
      103. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)
      104. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)
      105. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      106. rx.Subscriber.setProducer(Subscriber.java:211)
      107. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      108. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      109. rx.Observable.unsafeSubscribe(Observable.java:10211)
      110. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      111. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      112. rx.Observable.unsafeSubscribe(Observable.java:10211)
      113. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      114. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      115. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      116. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      117. rx.Observable.unsafeSubscribe(Observable.java:10211)
      118. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)
      119. rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)
      120. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      121. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      122. rx.Observable.unsafeSubscribe(Observable.java:10211)
      123. rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)
      124. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:50)
      125. rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:24)
      126. rx.Observable.unsafeSubscribe(Observable.java:10211)
      127. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      128. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      129. rx.Observable.unsafeSubscribe(Observable.java:10211)
      130. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      131. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      132. rx.Observable.unsafeSubscribe(Observable.java:10211)
      133. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
      134. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      135. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      136. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      137. rx.Observable.unsafeSubscribe(Observable.java:10211)
      138. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:235)
      139. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:228)
      140. rx.Observable.unsafeSubscribe(Observable.java:10211)
      141. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      142. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      143. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      144. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      145. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      146. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      147. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      148. rx.observers.Subscribers$5.onNext(Subscribers.java:235)
      149. rx.internal.operators.OperatorDistinct$1.onNext(OperatorDistinct.java:63)
      150. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      151. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      152. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      153. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      154. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      155. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      156. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      157. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      157 frames
    12. 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
    13. rxjava
      OperatorSubscribeOn$1$1$1.request
      1. rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)
      1 frame
    14. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    15. 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
    16. 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
    17. 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
    18. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    19. 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.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      19. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      20. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.fastPath(OnSubscribeFromArray.java:76)
      21. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:58)
      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.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      26. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      27. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      28. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      29. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
      30. rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
      31. rx.Observable.unsafeSubscribe(Observable.java:10211)
      32. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
      33. rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
      34. rx.Observable.unsafeSubscribe(Observable.java:10211)
      35. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      36. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      37. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      38. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      39. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      40. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      41. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      42. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      43. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      44. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      45. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      46. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      46 frames
    20. 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
    21. 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
    22. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    23. 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
    24. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    25. 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
    26. 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
    27. 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
    28. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    29. 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
    30. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    31. 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.OnSubscribeMap.call(OnSubscribeMap.java:48)
      64. rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
      65. rx.Observable.unsafeSubscribe(Observable.java:10211)
      66. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      67. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      68. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      69. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      70. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      71. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      72. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      73. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      73 frames
    32. com.github.davidmoten
      QueryUpdateOnSubscribe$2.onNext
      1. com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe$2.onNext(QueryUpdateOnSubscribe.java:279)
      1 frame
    33. 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
    34. 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
    35. rxjava
      OperatorSubscribeOn$1$1$1.request
      1. rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)
      1 frame
    36. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    37. 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
    38. 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
    39. 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
    40. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    41. 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
    42. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    43. 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
    44. 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
    45. 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
    46. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    47. 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
    48. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    49. 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.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:235)
      45. rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:228)
      46. rx.Observable.unsafeSubscribe(Observable.java:10211)
      47. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      48. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      49. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      50. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      51. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      52. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      53. rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)
      54. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)
      55. rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)
      56. rx.Subscriber.setProducer(Subscriber.java:211)
      57. rx.internal.operators.OnSubscribeFilter$FilterSubscriber.setProducer(OnSubscribeFilter.java:104)
      58. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)
      59. rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)
      60. rx.Observable.unsafeSubscribe(Observable.java:10211)
      61. rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:45)
      62. rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:30)
      63. rx.Observable.unsafeSubscribe(Observable.java:10211)
      64. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      65. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      66. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      67. rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)
      68. rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)
      69. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)
      70. rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)
      71. rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)
      72. rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)
      73. rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)
      74. rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)
      75. rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)
      75 frames
    50. 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
    51. rxjava
      OperatorSubscribeOn$1$1$1.request
      1. rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)
      1 frame
    52. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    53. 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
    54. 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
    55. 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
    56. rx.internal.producers
      ProducerArbiter.setProducer
      1. rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)
      1 frame
    57. rxjava
      ExecutorScheduler$ExecutorSchedulerWorker.run
      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.OnSubscribeFilter.call(OnSubscribeFilter.java:45)
      19. rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:30)
      20. rx.Observable.unsafeSubscribe(Observable.java:10211)
      21. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
      22. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
      23. rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
      24. rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)
      25. rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)
      26. rx.internal.operators.OnSubscribeTimerPeriodically$1.call(OnSubscribeTimerPeriodically.java:52)
      27. rx.Scheduler$Worker$1.call(Scheduler.java:137)
      28. rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)
      29. rx.internal.schedulers.ExecutorScheduler$ExecutorSchedulerWorker.run(ExecutorScheduler.java:107)
      29 frames
    58. 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