Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via GitHub by thomasnield
, 1 year ago
This exception has no message.
via GitHub by thomasnield
, 1 year ago
This exception has no message.
java.lang.NullPointerException: 	at com.github.davidmoten.rx.jdbc.ConnectionProviderBatch.close(ConnectionProviderBatch.java:24)	at com.github.davidmoten.rx.jdbc.Database.endTransactionObserve(Database.java:687)	at com.github.davidmoten.rx.jdbc.QueryContext.endTransactionObserve(QueryContext.java:57)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:91)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at com.github.davidmoten.rx.internal.operators.OnSubscribeMapLast$MapLastSubscriber.onNext(OnSubscribeMapLast.java:97)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at com.github.davidmoten.rx.internal.operators.OperatorFromTransformer$ParentSubscriber.onNext(OperatorFromTransformer.java:93)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)	at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)	at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.DeferredScalarSubscriber.complete(DeferredScalarSubscriber.java:100)	at rx.internal.operators.DeferredScalarSubscriber.onCompleted(DeferredScalarSubscriber.java:73)	at rx.internal.operators.DeferredScalarSubscriberSafe.onCompleted(DeferredScalarSubscriberSafe.java:54)	at rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)	at rx.internal.operators.OnSubscribeRedo$4$1.onCompleted(OnSubscribeRedo.java:321)	at rx.internal.operators.OperatorDematerialize$1.onCompleted(OperatorDematerialize.java:85)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)	at rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:298)	at rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:284)	at rx.internal.operators.NotificationLite.accept(NotificationLite.java:152)	at rx.subjects.SubjectSubscriptionManager$SubjectObserver.emitNext(SubjectSubscriptionManager.java:255)	at rx.subjects.BehaviorSubject.onNext(BehaviorSubject.java:162)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.subjects.SerializedSubject.onNext(SerializedSubject.java:67)	at rx.internal.operators.OnSubscribeRedo$2$1.onCompleted(OnSubscribeRedo.java:228)	at com.swa.rm.common.util.OperatorEmissionCounter$call$parent$1.onCompleted(RxOperators.kt:210)	at com.swa.rm.common.util.OperatorEmissionCounter$call$parent$1.onCompleted(RxOperators.kt:210)	at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)	at rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)	at rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)	at rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onCompleted(OperatorBufferWithSize.java:130)	at rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)	at rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)	at rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)	at rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeRedo$2.call(OnSubscribeRedo.java:273)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OnSubscribeRedo$5.request(OnSubscribeRedo.java:361)	at rx.internal.operators.DeferredScalarSubscriber.setProducer(DeferredScalarSubscriber.java:143)	at rx.Subscriber.setProducer(Subscriber.java:205)	at rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:353)	at rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:47)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)	at rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:50)	at rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)	at rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:40)	at rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.DeferredScalarSubscriber.complete(DeferredScalarSubscriber.java:100)	at rx.internal.operators.DeferredScalarSubscriber.onCompleted(DeferredScalarSubscriber.java:73)	at rx.internal.operators.DeferredScalarSubscriberSafe.onCompleted(DeferredScalarSubscriberSafe.java:54)	at rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)	at rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)	at rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onCompleted(OperatorBufferWithSize.java:130)	at rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)	at rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)	at rx.observers.SerializedObserver.onCompleted(SerializedObserver.java:177)	at rx.observers.SerializedSubscriber.onCompleted(SerializedSubscriber.java:64)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:246)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onCompleted(OnSubscribeConcatMap.java:169)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:106)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)	at rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:50)	at rx.internal.operators.OnSubscribeCollect.call(OnSubscribeCollect.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:235)	at rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:228)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)	at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)	at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)	at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)	at rx.observers.Subscribers$5.onNext(Subscribers.java:235)	at rx.internal.operators.OperatorDistinct$1.onNext(OperatorDistinct.java:63)	at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)	at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)	at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.processRow(QuerySelectProducer.java:115)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.requestSome(QuerySelectProducer.java:76)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.request(QuerySelectProducer.java:48)	at rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)	at com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:69)	at com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:20)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request(OnSubscribeConcatMap.java:366)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:278)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.fastPath(OnSubscribeFromArray.java:76)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:58)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)	at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)	at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)	at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.performUpdate(QueryUpdateOnSubscribe.java:259)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:88)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)	at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)	at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)	at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.performUpdate(QueryUpdateOnSubscribe.java:259)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:88)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)	at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)	at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.DeferredScalarSubscriber.subscribeTo(DeferredScalarSubscriber.java:153)	at rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:40)	at rx.internal.operators.OnSubscribeReduceSeed.call(OnSubscribeReduceSeed.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe$2.onNext(QueryUpdateOnSubscribe.java:279)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.processRow(QuerySelectProducer.java:115)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.requestAll(QuerySelectProducer.java:56)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.request(QuerySelectProducer.java:46)	at rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)	at com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:69)	at com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:20)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request(OnSubscribeConcatMap.java:366)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:278)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.performUpdate(QueryUpdateOnSubscribe.java:247)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:88)	at com.github.davidmoten.rx.jdbc.QueryUpdateOnSubscribe.call(QueryUpdateOnSubscribe.java:22)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OperatorBufferWithSize$BufferExact.onNext(OperatorBufferWithSize.java:114)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:117)	at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:89)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)	at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)	at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)	at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)	at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:235)	at rx.internal.util.ScalarSynchronousObservable$3.call(ScalarSynchronousObservable.java:228)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)	at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)	at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)	at rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFilter$FilterSubscriber.setProducer(OnSubscribeFilter.java:104)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:45)	at rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:399)	at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:357)	at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:852)	at rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.onNext(OnSubscribeConcatMap.java:335)	at rx.internal.operators.OperatorSubscribeOn$1$1.onNext(OperatorSubscribeOn.java:53)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.processRow(QuerySelectProducer.java:115)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.requestSome(QuerySelectProducer.java:76)	at com.github.davidmoten.rx.jdbc.QuerySelectProducer.request(QuerySelectProducer.java:48)	at rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerSubscriber.setProducer(OnSubscribeConcatMap.java:329)	at rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)	at com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:69)	at com.github.davidmoten.rx.jdbc.QuerySelectOnSubscribe.call(QuerySelectOnSubscribe.java:20)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)	at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:45)	at rx.internal.operators.OperatorSubscribeOn.call(OperatorSubscribeOn.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:286)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.observers.SerializedObserver.onNext(SerializedObserver.java:92)	at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request(OnSubscribeConcatMap.java:366)	at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:278)	at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.slowPath(OnSubscribeFromArray.java:100)	at rx.internal.operators.OnSubscribeFromArray$FromArrayProducer.request(OnSubscribeFromArray.java:63)	at rx.Subscriber.setProducer(Subscriber.java:211)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:32)	at rx.internal.operators.OnSubscribeFromArray.call(OnSubscribeFromArray.java:24)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)	at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94)	at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:45)	at rx.internal.operators.OnSubscribeFilter.call(OnSubscribeFilter.java:30)	at rx.Observable.unsafeSubscribe(Observable.java:10211)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)	at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)	at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)	at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101)	at rx.internal.operators.OnSubscribeFilter$FilterSubscriber.onNext(OnSubscribeFilter.java:76)	at rx.internal.operators.OnSubscribeTimerPeriodically$1.call(OnSubscribeTimerPeriodically.java:52)	at rx.Scheduler$Worker$1.call(Scheduler.java:137)	at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)	at rx.internal.schedulers.ExecutorScheduler$ExecutorSchedulerWorker.run(ExecutorScheduler.java:107)	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)	at java.lang.Thread.run(Thread.java:745)