2016-10-27 8 views
1

私は、retrofit2を使用してログインして連絡先をダウンロードするrxjavaチェーンを持っています。しかし中途半端に私はアンドロイド2.3.3デバイス上でstackoverflowerrorを取得します。関数呼び出しの連鎖を減らす方法はありますか?rxjavaチェーンのstackoverflowerror

W: java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker thread. 
W:  at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:59) 
W:  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:444) 
W:  at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:306) 
W:  at java.util.concurrent.FutureTask.run(FutureTask.java:138) 
W:  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:153) 
W:  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:267) 
W:  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1088) 
W:  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:581) 
W:  at java.lang.Thread.run(Thread.java:1019) 
W: Caused by: java.lang.StackOverflowError 
W:  at okhttp3.HttpUrl.canonicalize(HttpUrl.java:1795) 
W:  at okhttp3.HttpUrl$Builder.push(HttpUrl.java:1429) 
W:  at okhttp3.HttpUrl$Builder.resolvePath(HttpUrl.java:1420) 
W:  at okhttp3.HttpUrl$Builder.parse(HttpUrl.java:1379) 
W:  at okhttp3.HttpUrl.newBuilder(HttpUrl.java:874) 
W:  at okhttp3.HttpUrl.resolve(HttpUrl.java:849) 
W:  at retrofit2.RequestBuilder.build(RequestBuilder.java:190) 
W:  at retrofit2.ServiceMethod.toRequest(ServiceMethod.java:112) 
W:  at retrofit2.OkHttpCall.createRawCall(OkHttpCall.java:178) 
W:  at retrofit2.OkHttpCall.request(OkHttpCall.java:61) 
W:  at *snip*.retrofit.ErrorCallAdapter$1.adapt(ErrorCallAdapter.java:47) 
W:  at *snip*.retrofit.ErrorCallAdapter$1.adapt(ErrorCallAdapter.java:39) 
W:  at retrofit2.Retrofit$1.invoke(Retrofit.java:147) 
W:  at $Proxy4.roster(Native Method) 
W:  at *snip*.managers.ContactManager$1.call(ContactManager.java:148) 
W:  at *snip*.managers.ContactManager$1.call(ContactManager.java:145) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:69) 
W:  at rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102) 
W:  at rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85) 
W:  at rx.internal.operators.OnSubscribeFromCallable.call(OnSubscribeFromCallable.java:48) 
W:  at rx.internal.operators.OnSubscribeFromCallable.call(OnSubscribeFromCallable.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) 
W:  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) 
W:  at rx.observers.SerializedObserver.onNext(SerializedObserver.java:91) 
W:  at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94) 
W:  at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.innerNext(OnSubscribeConcatMap.java:182) 
W:  at rx.internal.operators.OnSubscribeConcatMap$ConcatMapInnerScalarProducer.request(OnSubscribeConcatMap.java:366) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.drain(OnSubscribeConcatMap.java:278) 
W:  at rx.internal.operators.OnSubscribeConcatMap$ConcatMapSubscriber.onNext(OnSubscribeConcatMap.java:144) 
W:  at rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102) 
W:  at rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85) 
W:  at rx.internal.operators.OperatorToObservableList$1.onCompleted(OperatorToObservableList.java:98) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:656) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:568) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onCompleted(OperatorMerge.java:281) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onCompleted(OperatorOnErrorResumeNextViaFunction.java:101) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onCompleted(OperatorMapResponseToBodyOrError.java:48) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:184) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.setProducer(OperatorOnErrorResumeNextViaFunction.java:159) 
W:  at rx.Subscriber.setProducer(Subscriber.java:205) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94) 
W:  at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) 
W:  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) 
W:  at rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102) 
W:  at rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85) 
W:  at rx.internal.operators.OnSubscribeFromCallable.call(OnSubscribeFromCallable.java:48) 
W:  at rx.internal.operators.OnSubscribeFromCallable.call(OnSubscribeFromCallable.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:511) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:466) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:244) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) 
W:  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onNext(OperatorOnErrorResumeNextViaFunction.java:154) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:41) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:38) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:173) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.setProducer(OperatorOnErrorResumeNextViaFunction.java:159) 
W:  at rx.Subscriber.setProducer(Subscriber.java:205) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) 
W:  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onNext(OperatorOnErrorResumeNextViaFunction.java:154) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:41) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:38) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:173) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.setProducer(OperatorOnErrorResumeNextViaFunction.java:159) 
W:  at rx.Subscriber.setProducer(Subscriber.java:205) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) 
W:  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onNext(OperatorOnErrorResumeNextViaFunction.java:154) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:41) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:38) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:173) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.setProducer(OperatorOnErrorResumeNextViaFunction.java:159) 
W:  at rx.Subscriber.setProducer(Subscriber.java:205) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) 
W:  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onNext(OperatorOnErrorResumeNextViaFunction.java:154) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:41) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:38) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:173) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.setProducer(OperatorOnErrorResumeNextViaFunction.java:159) 
W:  at rx.Subscriber.setProducer(Subscriber.java:205) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) 
W:  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onNext(OperatorOnErrorResumeNextViaFunction.java:154) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:41) 
W:  at retrofit2.adapter.rxjava.OperatorMapResponseToBodyOrError$1.onNext(OperatorMapResponseToBodyOrError.java:38) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$RequestArbiter.request(RxJavaCallAdapterFactory.java:173) 
W:  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) 
W:  at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.setProducer(OperatorOnErrorResumeNextViaFunction.java:159) 
W:  at rx.Subscriber.setProducer(Subscriber.java:205) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:152) 
W:  at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:138) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
W:  at rx.Observable.unsafeSubscribe(Observable.java:10200) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) 
W:  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) 
W:  at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) 

ect。

ほとんどの場合、.flatMap()でチェーンされています。これには良い選択肢がありますか?

+1

何か助けが必要な場合は、コードを投稿してください。 –

+1

アドバイス:コードを最適化してください。メモリ使用量、割り当てトラッカー出力を分析します。あなたが作成する 'Observable'型のオブジェクトの量を確認してください。 –

答えて

-2

Observable.zip()を使用してさらに多くのものを並列処理することで修正することができました。うまくいけば、私は競争条件を作りませんでした...

+0

あなたはここで終わるのを助けるための十分な情報がなくても、私たちが助けて、答えるのに十分な情報なしに質問を書いています。少なくとも完全な答えを出す。 – AxelH

関連する問題