fix toUni()

projectnessie · May 30, 2024 · 6e8930d · 6e8930d
1 parent e9228c1
commit 6e8930d
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...est/src/main/java/org/projectnessie/catalog/service/rest/IcebergApiV1GenericResource.java b/...est/src/main/java/org/projectnessie/catalog/service/rest/IcebergApiV1GenericResource.java
@@ -122,14 +122,16 @@ public Uni<Response> s3sign(
     ContentKey key = ContentKey.fromPathString(identifier);
     String requestedS3Uri = S3Utils.asS3Location(request.uri());
 
-    return collectBasePrefixes(decodedPrefix, key)
+    return collectLocations(decodedPrefix, key)
         .filter(requestedS3Uri::startsWith)
-        .map(ignored -> doRequestSign(request))
         .toUni()
+        .onItem()
+        .ifNotNull()
+        .transform(ignored -> doRequestSign(request))
         .replaceIfNullWith(() -> signingRequestDenied(request));
   }
 
-  private Multi<String> collectBasePrefixes(DecodedPrefix decodedPrefix, ContentKey key)
+  private Multi<String> collectLocations(DecodedPrefix decodedPrefix, ContentKey key)
       throws NessieNotFoundException {
 
     WarehouseConfig warehouse = catalogConfig.getWarehouse(decodedPrefix.warehouse());