java.lang.NullPointerException

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