RxActivityResult不回调onComplete

[YuYongzhi]

RxActivityResult.startActivityForResult(this, intent, REQUEST_CODE)
.subscribe(
new Consumer() {
@OverRide
public void accept(@nonnull ActivityResult result) throws Exception {
if (result.isOk()) {
final Intent data = result.getData();
// DO SOME THING
}
}
},
new Consumer() {
@OverRide
public void accept(@io.reactivex.annotations.NonNull Throwable throwable) throws Exception {
}
},
new Action() {
@OverRide
public void run() throws Exception {

                        }
                    }
            );

在ResultHandleV4Fragment 和 ResultHandleFragment 的 onActivityResult 中的
resultPublisher.onNext(new ActivityResult(requestCode, resultCode, data));
之后添加
resultPublisher.onComplete();