在RxJava2中创建去保管器

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

public class RxJavaExample {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(emitter -> {
            // 执行异步任务，例如网络请求或数据库查询
            // 在适当的时候调用emitter.onNext()发送数据
            // 在出现错误时调用emitter.onError()发送错误信息
            // 在任务完成时调用emitter.onComplete()结束数据流
        });

        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 获取去保管器对象，可以在需要的时候取消订阅
            }

            @Override
            public void onNext(String s) {
                // 处理接收到的数据
            }

            @Override
            public void onError(Throwable e) {
                // 处理发生的错误
            }

            @Override
            public void onComplete() {
                // 处理数据流结束的情况
            }
        };

        observable.subscribe(observer);
    }
}