java - 如何在 RxJava 中获得多个响应?

标签 java rx-java rx-java2

我有下面的代码,我想知道如何能够获得除设置的 Boolean 值之外的其他响应:

public Single<Boolean> uploadFile(String entityType, String entityId, String blobName){
    return Single.create(e -> {
        uploadElement = DOM.createElement("input");
        uploadElement.setAttribute("type", "file");
        uploadElement.setAttribute("accept", "*/*");;
        Event.sinkEvents(uploadElement, Event.ONCHANGE);
        Event.setEventListener(uploadElement, event -> {
            final FileObject fileObject = (FileObject) getFile(event);
            log("Name=" + fileObject.getName());
            log("Type=" + fileObject.getType());
            log("Size=" + fileObject.getSize() + "");
            readAsDataURL((FileObject) fileObject, new FileReaderCallback() {
                @Override
                public void onLoad(String data) {
                        Entity entity = new Entity(entityType);
                        entity.setEntityId(entityId);
                        entity.setBlobProperty(blobName, data).subscribe(isSuccess -> {
                            e.onSuccess(isSuccess);
                        }, error -> {
                            e.onError(error);
                        });
                }
            });
        });
        click();
    });
}

我还需要能够在进程中获取FileObject,我该如何在 RxJava 中做到这一点?

最佳答案

查看 zip 运算符。这使得你的结果加上你在 zip 运算符中放入的内容组成一个元组。 您可能需要稍微重组您的程序。

关于java - 如何在 RxJava 中获得多个响应?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52432499/

相关文章:

rx-java - 一个操作符默认不对任何特定的 Scheduler 进行操作是什么意思

java - 从另一个可观察到的无限可观察

java - Retrofit 2 类文件问题

java - 如何在 eclipse 项目中使用 Firebase 云消息?

java - Spark 提交 : --packages vs --jars

android - 无法解析 RXJava 依赖项

kotlin - 如何将 concat 与 lambda 和 ObservableSource 一起使用

java - rx-java2:重复 Maybe/Flowable 除非为空

java - 想要使 "System.out.println()"将消息打印到 log4j

java - 如何使Intellij处理build.gradle中引用的@NotNull批注