Spring Reactor: Mono.zip schlägt auf leer Mono

Question

Ich benutze Spring Reactor 3.1.0.M3 und habe einen Anwendungsfall, wo ich Monos aus mehreren Quellen zusammenführen muss. Ich fand, dass, wenn eines der Monos ein leeres Mono ist, zip ohne Fehler fehlschlägt.

Beispiel:

Mono<String> m1 = Mono.just("A"); 
Mono<String> m2 = Mono.just("B"); 
Mono<String> m3 = Mono.empty(); 

Mono<String> combined = Mono.zip(strings -> { 
    StringBuffer sb = new StringBuffer(); 
    for (Object string : strings) { 
     sb.append((String) string); 
    } 
    return sb.toString(); 
}, m1, m2, m3); 
System.out.println("Combined " + combined.block()); 

Wenn m3 zugesetzt wird, wird der Kombinator in der Antwort übersprungen ist null. Wenn ich m3 entferne, funktioniert alles wie erwartet und "AB" wird zurückgegeben. Gibt es eine Möglichkeit, das zu umgehen, indem ich das leere Mono erkenne? Gibt es auch eine Möglichkeit, dass die Kombinator-Methode den Typ des Objekts kennt, anstatt zu casten?

Answer 1

Der Zip-Operator verhält sich nicht so. Es wäre in der Tat kontraintuitiv: Ihr Code erwartet ein Tuple von 3 Elementen und Sie bekommen nur zwei?!?

In diesem Fall haben Sie die Kontrolle und nur Sie können entscheiden, was ein guter Standardwert ist, wenn keiner bereitgestellt wird (denken Sie daran, null Werte sind durch die reaktive Streams-Spezifikation verboten).

Mono<String> m1 = Mono.just("A"); 
Mono<String> m2 = Mono.just("B"); 
Mono<String> m3 = Mono.empty().defaultIfEmpty(""); 

Mono<String> combined = Mono.when(m1, m2, m3).map(t -> { 
    StringBuffer sb = new StringBuffer(); 
    sb.append(t.getT1()); 
    sb.append(t.getT2()); 
    sb.append(t.getT3()); 
    return sb.toString(); 
}); 

bearbeiten

Sie scheinen von der Natur eines Publisher Art verwechselt werden, siehe:

, wenn einer der Monos eine leere Mono ist, schlägt zip ohne einen Fehler

und

Also, wenn ich war und zip Monos, um zu versuchen und aus irgendeinem Grund ein leer ist, würde die zip scheitern, und ich kann nicht gegen diese

Eine leere Mono zu sichern in jedem Code zu setzen scheinen kein Fehlerfall : Es wird nur kein Wert ausgegeben und es wird erfolgreich abgeschlossen. Sie können das überprüfen, indem Sie das Codebeispiel zu ändern:

combined.subscribe(
      s -> System.out.println("element: " + s), // doesn't execute 
      s -> System.out.println("error: " + s), // doesn't execute 
      () -> { System.out.println("complete!"); // prints 
    }); 

Also je nach Ihren Anforderungen können Sie:

• einen defaultIfEmpty Betreiber auf diesen 3 Mono Instanzen anwenden, wenn es bequem sind Standardwerte können Sie verlassen sich auf
• anwenden einen defaultIfEmpty Operator auf dem kombinierten Mono, mit einem Standardwert, oder sogar, dass in einer Fehlermeldung Transformation mit combined.switchIfEmpty(Mono.error(...))