反应器（Spring流量）

Question

我用的是Spring助焊剂。我需要从不同的来源组装一个物体。如何确保两个流都返回了所需的数据？

比如：

 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

    }

Answer 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-