@@ -516,7 +516,7 @@ void shouldBatchDecrypt() {
516516 assertThat (two ).isNotNull ();
517517
518518 this .reactiveTransitOperations .decrypt ("myKey" , Arrays .asList (one , two ))
519- .zipWith (Flux .merge (this .reactiveTransitOperations .decrypt ("myKey" , one ),
519+ .zipWith (Flux .concat (this .reactiveTransitOperations .decrypt ("myKey" , one ),
520520 this .reactiveTransitOperations .decrypt ("myKey" , two )))
521521 .as (StepVerifier ::create )
522522 .assertNext (it -> {
@@ -860,7 +860,7 @@ void shouldExportEcDsaKey() {
860860 .build ();
861861
862862 this .reactiveTransitOperations .createKey ("myKey" , request )
863- .thenMany (Flux .merge (this .reactiveTransitOperations .exportKey ("myKey" , TransitKeyType .HMAC_KEY ),
863+ .thenMany (Flux .concat (this .reactiveTransitOperations .exportKey ("myKey" , TransitKeyType .HMAC_KEY ),
864864 this .reactiveTransitOperations .exportKey ("myKey" , TransitKeyType .SIGNING_KEY )))
865865 .as (StepVerifier ::create )
866866 .assertNext (hmacKey -> assertThat (hmacKey .getKeys ()).isNotEmpty ())
@@ -877,7 +877,7 @@ void shouldExportEdKey() {
877877 .build ();
878878
879879 this .reactiveTransitOperations .createKey ("myKey" , request )
880- .thenMany (Flux .merge (this .reactiveTransitOperations .exportKey ("myKey" , TransitKeyType .HMAC_KEY ),
880+ .thenMany (Flux .concat (this .reactiveTransitOperations .exportKey ("myKey" , TransitKeyType .HMAC_KEY ),
881881 this .reactiveTransitOperations .exportKey ("myKey" , TransitKeyType .SIGNING_KEY )))
882882 .as (StepVerifier ::create )
883883 .assertNext (hmacKey -> assertThat (hmacKey .getKeys ()).isNotEmpty ())
0 commit comments