java.lang.NullPointerException

GitHub | thomasnield | 5 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.

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