在Spring Boot 2 with Reactor中，我試圖合并兩個(gè)熱源。但是，似乎唯一一個(gè)報(bào)告了 中的兩個(gè)參數(shù)中的第一個(gè)。我如何識(shí)別第二個(gè).FluxmergeFluxmergemergeFlux在下面的示例中，in 甚至不會(huì)打印 when 是第一個(gè)參數(shù)。如果我做第一個(gè)，那么不打印。System.errB-2outgoing1aoutgoing2A-2以下是完整的示例;package com.example.demo;import java.time.Duration;import java.util.concurrent.BlockingQueue;import java.util.concurrent.LinkedBlockingQueue;import reactor.core.publisher.Flux;import reactor.core.scheduler.Schedulers;public class Weather {String city;Integer temperature;public Weather(String city, Integer temperature) {    this.city = city;    this.temperature = temperature;}@Overridepublic String toString() {    return "Weather [city=" + city + ", temperature=" + temperature + "]";}public static void main(String[] args) {    BlockingQueue<Weather> queue = new LinkedBlockingQueue<>();    BlockingQueue<Weather> queue2 = new LinkedBlockingQueue<>();    // Assume Spring @Repository "A-1"    new Thread(() -> {        for (int d = 1; d < 1000; d += 1) {            for (String s: new String[] {"LDN", "NYC", "PAR", "ZUR"}) {                queue.add(new Weather(s, d));                try { Thread.sleep(250); } catch (InterruptedException e) {}            }        }    }).start();     // Assume Spring @Repository "B-1"    new Thread(() -> {        for (int d = 1; d < 1000; d += 1) {            for (String s: new String[] {"MOS", "TLV"}) {                queue2.add(new Weather(s, d));                try { Thread.sleep(1000); } catch (InterruptedException e) {}            }        }    }).start();    // Assume Spring @Service "A-2" = real-time LDN, NYC, PAR, ZUR    Flux<Weather> outgoing1 = Flux.<Weather>create(        sink -> {            for (int i = 0; i < 1000; i++) {                try {                    sink.next(queue.take());                    System.err.println("1 " + queue.size());                } catch (InterruptedException e) {                    e.printStackTrace();                }            }            sink.complete();        }    )