如何退订广播接收器中的RXjava呼叫

Question

我正在使用RXJava2在广播接收器中发送电子邮件，我想知道何时应该退订该事件。代码基本上是：

        getSmsMmsObservable()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .doOnError(throwable -> Timber.e(throwable, "Error sending mail."))
            .map(smsMmsAddress1 -> {
                smsMmsAddress = smsMmsAddress1;
                return doInBackgroundSendEmail();
            })
            .map(stringSingle -> {
                mMsgResponse = stringSingle;
                this.done = true;
                return deleteFile();
            })
            .subscribe(success -> {
                if (success) {
                    Toast.makeText(context, "Message Status: " + mMsgResponse, Toast.LENGTH_LONG).show();
                }

            });

我什么时候退订（接收器中没有onPause或onDestroy），我怎么知道onReceive何时完成？接收者通过清单进行注册。我考虑过做一个可观​​察的复合物，然后在subscribe（）部分中将其处理。

    compositeDisposable.add(
    getSmsMmsObservable()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .doOnError(throwable -> Timber.e(throwable, "Error sending mail."))
            .map(smsMmsAddress1 -> {
                smsMmsAddress = smsMmsAddress1;
                return doInBackgroundSendEmail();
            })
            .map(stringSingle -> {
                mMsgResponse = stringSingle;
                this.done = true;
                return deleteFile();
            })
            .subscribe(success -> {
                if (success) {
                    Toast.makeText(context, "Message Status: " + mMsgResponse, Toast.LENGTH_LONG).show();
                }
                compositeDisposable.dispose();

            })
    );

Answer 1

如此处所指出的，您不应在广播接收机上执行冗长的任务。
广播接收器没有生命周期，当您的onReceive返回它被系统认为已经完成并且您的整个过程之后可能会被终止时，它将在您执行异步处理时立即返回您的情况。（在https://developer.android.com/guide/components/broadcasts.html “进程状态的影响”下了解更多信息）。

您应该为此任务创建专用的服务，并执行在那里发送的电子邮件，并且服务的生命周期明确，您应该在退订onDestory()。还应注意从棉花糖和Doze开始的有限后台处理和Internet访问。

无论如何，您都不应该在onNext/处进行处置onCompleted，而Observable在终止（onCompleted/ onError）时将触发处置逻辑。