纯 Java 项目的 saveInBackground 失效

[login950518]

import cn.leancloud.AVObject;
import cn.leancloud.core.AVOSCloud;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
import org.jetbrains.annotations.NotNull;

public class ForSendDemo {

    public static void main(String[] args) {
        AVOSCloud.initialize("QIagxVbqJ4eejWOLXHnhxtSz-gzGzoHsz", "KIBcfgzTheg0JW5USz1rEqnb");

        System.out.println("准备初始化");
        System.out.println("初始化完成");
        // 构建对象
        AVObject todo = new AVObject("Todo");

        // 为属性赋值
        todo.put("title", "马拉松报名");
        todo.put("priority", 2);

        // 将对象保存到云端
        todo.saveInBackground().subscribe(new Observer<AVObject>() {
            public void onSubscribe(Disposable disposable) {}
            public void onNext(AVObject todo) {
                // 成功保存之后，执行其他逻辑
                System.out.println("保存成功。objectId：" + todo.getObjectId());
            }
            public void onError(Throwable throwable) {
                // 异常处理
            }
            public void onComplete() {}
        });
    }
}

但是无法执行；
如果使用 todo 就可以。。

[weakish]

因为保存文件是异步的，还没有来得及收到 Next 事件整个程序就退出了，System.out.println("保存成功。objectId：" + todo.getObjectId()); 就没有机会执行了。

推荐您了解下 RxJava 的基本原理。

另外，如果您更习惯以同步的方式调用程序，那么可以用 todo.save() （这是一个同步接口）。其实 SDK 的很多异步方法都提供了同步版本。如果 SDK 没有提供，那么大多数情况下您也可以使用 blockingFirst()，比如 todo.saveInBackground().blockingFirst()。

[login950518]

blo

十分感谢！！