反应堆（ spring 通量）-Java 学习之路

我正在使用Spring Flux . 我需要从不同的来源组装一个Object . 我怎样才能确定两个流都返回了所需的数据？

喜欢：

public Mono<MyObject> createMyObject() {

        MyObject myObject = new MyObject();

        someService.getSomeData().subscribe(myObject::setData);
        oneMoreService.getMoreData().subscribe(list -> {
            // myObject populate more fields
        });

        // how can I be sure that someData and moreData is populated, before we reach doSomeBusinessStuff method?
        return Mono.just(myObject);
    }

 public Result doSomeBusinessStuff(Mono<MyObject> myObject) {

        // make some other calculations with someData and moreData

    }

1 回答

你可以压缩它们 .

return Mono.zip(someService.getSomeData(), oneMoreService.getMoreData())
        .map(t -> {              
            X data1 = t.getT1();
            Y data2 = t.getT2();

            MyObject myObject = new MyObject();
            //...
            return myObject;
        });

您可以在文档中找到有关它的信息 . https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html#zip-reactor.core.publisher.Mono-reactor.core.publisher.Mono-

回复于 2024-05-03T06:43:48+08:00

反应堆（ spring 通量）

1 回答

相关问题