第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問題,去搜搜看,總會有你想問的

我如何手動(dòng)取消/處置 RXJava2 Flowable?

我如何手動(dòng)取消/處置 RXJava2 Flowable?

慕婉清6462132 2022-12-28 10:41:02
我有一個(gè)使用依賴于 RX Java 2的FileStack 依賴項(xiàng)io.reactivex.rxjava2:rxjava:2.1.2的 Android 項(xiàng)目。具體來說, . 直到現(xiàn)在這還不是真正的問題,因?yàn)槲乙恢睙o法弄清楚如何具體取消Flowable。我已經(jīng)實(shí)施了下面是我的代碼:private Flowable<Progress<FileLink>> upload;private void myMethod(){    upload = new Client(myConfigOptionsHere)      .uploadAsync(filePath, false, storageOptions);        upload.doOnNext(progress -> {                    double progressPercent = progress.getPercent();                    if(progressPercent > 0){                        //Updating progress here                    }                    if (progress.getData() != null) {                        //Sending successful upload callback here                    }                })                .doOnComplete(new Action() {                    @Override                    public void run() throws Exception {                        //Logging he complete action here                    }                })                .doOnCancel(new Action() {                    @Override                    public void run() throws Exception {                        //Logging the cancel here                    }                })                .doOnError(new Consumer<Throwable>() {                    @Override                    public void accept(Throwable t) throws Exception {                        //Logging the error here                    }                })                .subscribe();}public void cancelUpload(){    //What do I do here to manually stop the upload Flowable?     //IE upload.cancel();}我需要做什么/調(diào)用uploadFlowable 以便在用戶通過單擊按鈕取消上傳時(shí)我可以手動(dòng)觸發(fā)取消?我看到有人建議調(diào)用dispose,但在檢查可用于 Flowable 的可用方法時(shí)我沒有看到該選項(xiàng)。
查看完整描述

1 回答

?
隔江千里

TA貢獻(xiàn)1906條經(jīng)驗(yàn) 獲得超10個(gè)贊

原來問題是我試圖處理/取消錯(cuò)誤的對象。我將代碼調(diào)整為以下內(nèi)容:


private Disposable disposable;


private void myMethod(){

    Flowable<Progress<FileLink>> upload = new Client(myConfigOptionsHere)

      .uploadAsync(filePath, false, storageOptions);


        this.disposable = upload.doOnNext(progress -> {

                    double progressPercent = progress.getPercent();

                    if(progressPercent > 0){

                        //Updating progress here

                    }

                    if (progress.getData() != null) {

                        //Sending successful upload callback here

                    }

                })

                .doOnComplete(new Action() {

                    @Override

                    public void run() throws Exception {

                        //Logging he complete action here

                    }

                })

                .doOnCancel(new Action() {

                    @Override

                    public void run() throws Exception {

                        //Logging the cancel here

                    }

                })

                .doOnError(new Consumer<Throwable>() {

                    @Override

                    public void accept(Throwable t) throws Exception {

                        //Logging the error here

                    }

                })

                .subscribe();


}


public void cancelUpload(){

    if(this.disposable != null){

        this.disposable.dispose();

        this.disposable = null;

    }

}

并且能夠讓它正常工作。本質(zhì)上,您需要dispose()針對對象調(diào)用方法dispose,而不是Flowable.


感謝jschuss的幫助/留言


查看完整回答
反對 回復(fù) 2022-12-28
  • 1 回答
  • 0 關(guān)注
  • 144 瀏覽

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號