合并到 Observables / Singles 的方式有哪些？

Question

我有这段代码：

public void testGetBlob() throws RequestException {

    TestData.getNewApplication().flatMap(testApplication -> {

        Client.initialize(testApplication.getAppId(), testApplication.getApiToken(), testApplication.getMasterKey());

        assertNotNull(testApplication.getApiToken());

        assertNotNull(testApplication.getAppId());

        assertNotNull(testApplication.getMasterKey());

        Entity entity = new Entity("Todo");

        return entity.create();

    }).flatMap(entity -> entity.setBlobProperty("text", "Hello world!".getBytes("UTF-8")))

            .flatMap(isSuccess -> {

                if(isSuccess) {

                    // need to access `entity` at this point

                    return Single.just(isSuccess);

                } else {

                    return Single.just(false);

                }

            }).subscribe(success -> {

        Browser.getWindow().getConsole().log("Blob created");

        finishTest();

    }, error -> {

        Browser.getWindow().getConsole().error(error.getMessage());

        fail();

    });

    delayTestFinish(5000);

}

在上面的代码中，我需要做的是能够访问entity注释中的对象。如何做呢？

Answer 1

在一个运算符和另一个运算符之间，您只能发出一种对象类型。在您的情况下，您正在发出一个布尔值，但您还希望能够访问 Entity 对象。解决方案是将两个值（实体对象和布尔值）包装在一个类中并发出该类。创建一个类来包装 Entity 的发射和 setBlobProperty 的结果。    class Pair {        private final Entity entity;        private final boolean success;        private Pair(Entity entity, boolean success) {            this.entity = entity;            this.success = success;        }        public Entity getEntity() {            return entity;        }        public boolean isSuccess() {            return success;        }    }然后更改您的代码以发出该类：public void testGetBlob() throws RequestException {    TestData.getNewApplication().flatMap(testApplication -> {// ...        return entity.create();    }).flatMap(entity ->         entity.setBlobProperty("text", "Hello world!".getBytes("UTF-8"))            // 1. Flat map the setBlobProperty call and emit a Pair with the entity and result            .flatMap(isSuccess -> Single.just(new Pair(entity, isSuccess)))    )            .flatMap(pair -> {                if(pair.isSuccess()) {                    // 2. entity is available here via pair.getEntity()                    return Single.just(isSuccess);                } else {                    return Single.just(false);                }            }).subscribe(success -> {// ...    }}Ps：不要创建自己的 Pair 类，而是检查此线程中的选项之一。如果您使用的是 Kotlin，则有一个Pair类。