如何使用RxJava包装登录函数

dependencies {
    implementation 'io.reactivex.rxjava3:rxjava:3.x.x'
}

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;

public class LoginWrapper {
    public Observable<Boolean> login(String username, String password) {
        return Observable.create(emitter -> {
            // 执行登录逻辑
            boolean success = performLogin(username, password);
            
            // 发射登录结果
            emitter.onNext(success);
            emitter.onComplete();
        });
    }
    
    private boolean performLogin(String username, String password) {
        // 执行实际的登录操作
        // 返回登录结果
    }
}

public class Main {
    public static void main(String[] args) {
        LoginWrapper loginWrapper = new LoginWrapper();
        
        loginWrapper.login("username", "password")
            .subscribe(new Observer<Boolean>() {
                @Override
                public void onSubscribe(Disposable d) {
                    // 订阅时的操作
                }
                
                @Override
                public void onNext(Boolean success) {
                    // 处理登录结果
                }
                
                @Override
                public void onError(Throwable e) {
                    // 处理登录错误
                }
                
                @Override
                public void onComplete() {
                    // 登录流程完成
                }
            });
    }
}