RxJava ²Ù×÷·û´¦Àí±íµ¥ÑéÖ¤ »òÕߵǼÎÊÌâ

Observable.combineLatest ·½·¨Ê¹ÓÃ

Observable.combineLatest<Observable1,Observable2,BiFunction<String,String,Bollean>>

    @SuppressWarnings("unchecked")
    @CheckReturnValue
    @SchedulerSupport(SchedulerSupport.NONE)
    public static <T1, T2, R> Observable<R> combineLatest(
            ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2,
            BiFunction<? super T1, ? super T2, ? extends R> combiner) {
        ObjectHelper.requireNonNull(source1, "source1 is null");
        ObjectHelper.requireNonNull(source2, "source2 is null");
        return combineLatest(Functions.toFunction(combiner), bufferSize(), source1, source2);
    }

Àý×Ó·½·¨1
Observable.combineLatest(RxTextView.textChanges(mRectEtMobile.mEditText),
        RxTextView.textChanges(mRectEtPwd.mEditText),
        BiFunction<CharSequence, CharSequence, Boolean> { mobile, password ->
            TextCheckUtil.checkMobilePhone(mobile.toString()) && password.length >= 6 && password.length <= 18
        })
        .compose(bindUntilEvent(ActivityEvent.DESTROY))
        .subscribe { aBoolean -> mBtnLogin.isEnabled = aBoolean }
Àý×Ó·½·¨2
Observable.combineLatest<String, String, Boolean>(
        RxTextView.textChanges(mRectEtMobile.mEditText).map { mobile -> mobile.toString() }
        , RxTextView.textChanges(mRectEtPwd.mEditText).map { password -> password.toString() }
        , BiFunction<String, String, Boolean> { mobile, password ->
    TextCheckUtil.checkMobilePhone(mobile) && password.length >= 6 && password.length <= 18
})
        .compose(bindUntilEvent(ActivityEvent.DESTROY))
        .subscribe { aBoolean -> mBtnLogin.isEnabled = aBoolean }