ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

android-CompositeDisposable.clear导致OkHttp抛出java.lang.IllegalStateException:不平衡的输入/退出

2019-10-11 04:25:19  阅读:472  来源: 互联网

标签:rx-java2 okhttp3 android rx-java okhttp


所以我有一个使用OkHttp的简单http请求.我使用Android上的RxJava进行此操作.我将此RxJava调用添加到CompositeDisposable中,然后在onStop上清除它.由于某种原因在下面触发了此异常.我对如何解决它不确定.

Caused by java.lang.IllegalStateException: Unbalanced enter/exit
       at okio.AsyncTimeout.enter(AsyncTimeout.java:73)
       at okio.AsyncTimeout$2.read(AsyncTimeout.java:235)
       at okio.RealBufferedSource.read(RealBufferedSource.java:47)
       at okhttp3.internal.http1.Http1Codec$AbstractSource.read(Http1Codec.java:363)
       at okhttp3.internal.http1.Http1Codec$FixedLengthSource.read(Http1Codec.java:407)
       at okio.RealBufferedSource.read(RealBufferedSource.java:47)
       at okhttp3.internal.cache.CacheInterceptor$1.read(CacheInterceptor.java:174)
       at okhttp3.internal.Util.skipAll(Util.java:175)
       at okhttp3.internal.Util.discard(Util.java:157)
       at okhttp3.internal.cache.CacheInterceptor$1.close(CacheInterceptor.java:202)
       at okio.RealBufferedSource.close(RealBufferedSource.java:469)
       at okio.RealBufferedSource$1.close(RealBufferedSource.java:453)
       at java.nio.channels.Channels$ReadableByteChannelImpl.implCloseChannel(Channels.java:255)
       at java.nio.channels.spi.AbstractInterruptibleChannel$1.interrupt(AbstractInterruptibleChannel.java:166)
       at java.lang.Thread.interrupt(Thread.java:957)
       at java.util.concurrent.FutureTask.cancel(FutureTask.java:146)
       at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.cancel(ScheduledThreadPoolExecutor.java:258)
       at io.reactivex.internal.schedulers.ScheduledRunnable.dispose(ScheduledRunnable.java:107)
       at io.reactivex.disposables.CompositeDisposable.dispose(CompositeDisposable.java:217)
       at io.reactivex.disposables.CompositeDisposable.dispose(CompositeDisposable.java:80)
       at io.reactivex.internal.schedulers.IoScheduler$EventLoopWorker.dispose(IoScheduler.java:210)
       at io.reactivex.Scheduler$DisposeTask.dispose(Scheduler.java:464)
       at io.reactivex.internal.disposables.DisposableHelper.dispose(DisposableHelper.java:125)
       at io.reactivex.internal.operators.observable.ObservableSubscribeOn$SubscribeOnObserver.dispose(ObservableSubscribeOn.java:74)
       at io.reactivex.internal.operators.observable.ObservableObserveOn$ObserveOnObserver.dispose(ObservableObserveOn.java:146)
       at io.reactivex.internal.disposables.DisposableHelper.dispose(DisposableHelper.java:125)
       at io.reactivex.observers.DisposableObserver.dispose(DisposableObserver.java:91)
       at io.reactivex.disposables.CompositeDisposable.dispose(CompositeDisposable.java:217)
       at io.reactivex.disposables.CompositeDisposable.clear(CompositeDisposable.java:183)
       at MyActivity.onStop(MyActivity.java:320)
       at android.app.Instrumentation.callActivityOnStop(Instrumentation.java:1297)
       at android.app.Activity.performStop(Activity.java:7159)
       at android.app.ActivityThread.performDestroyActivity(ActivityThread.java:4625)
       at android.app.ActivityThread.handleDestroyActivity(ActivityThread.java:4691)
       at android.app.ActivityThread.-wrap7(ActivityThread.java)
       at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1718)
       at android.os.Handler.dispatchMessage(Handler.java:102)
       at android.os.Looper.loop(Looper.java:154)
       at android.app.ActivityThread.main(ActivityThread.java:6732)
       at java.lang.reflect.Method.invoke(Method.java)
       at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:1520)
       at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:1410)

代码基本上是这样的:

Observable<Stuff> observable = Observable.create(new ObservableOnSubscribe<Stuff>() {
            @Override
            public void subscribe(@NonNull ObservableEmitter<Stuff> e) throws Exception {

           //do OkHttp stuff, call onNext(stuff). 

            }
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread());
        DisposableObserver<Stuff> disposableObserver = observable
            .subscribeWith(new DisposableObserver<Stuff>() {......});

        disposables.add(disposableObserver);

解决方法:

一些Android VM中存在一个错误,无法与新的D8编译器交互.

https://github.com/square/okhttp/issues/3641#issuecomment-370717021

Google最近改进了D8,以避免触发该错误.

标签:rx-java2,okhttp3,android,rx-java,okhttp
来源: https://codeday.me/bug/20191011/1890153.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有