fix: #565 batch requests issue

SAP · Nov 20, 2024 · 669bb0a · 669bb0a
1 parent b6895e2
commit 669bb0a
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 0 deletions.
diff --git a/...ain/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/AsynchronousProcessor.java b/...ain/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/AsynchronousProcessor.java
@@ -8,6 +8,8 @@
 import java.util.List;
 import java.util.Objects;
 
+import org.apache.olingo.server.api.OData;
+import org.apache.olingo.server.api.ServiceMetadata;
 import org.apache.olingo.server.api.processor.Processor;
 
 import io.vertx.core.Context;
@@ -90,4 +92,10 @@ private static Deque<List<Future<Void>>> processingStack() {
         }
         return processingStack;
     }
+
+    @Override
+    public void init(OData odata, ServiceMetadata serviceMetadata) {
+        // reset subpromise
+        subProcessPromise = null;
+    }
 }
diff --git a/src/main/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/BatchProcessor.java b/src/main/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/BatchProcessor.java
@@ -46,6 +46,7 @@ public BatchProcessor(Vertx vertx, RoutingContext routingContext, Promise<Void>
 
     @Override
     public void init(OData odata, ServiceMetadata serviceMetadata) {
+        super.init(odata, serviceMetadata);
         this.odata = odata;
     }
 

diff --git a/...io/neonbee/endpoint/odatav4/internal/olingo/processor/CountEntityCollectionProcessor.java b/...io/neonbee/endpoint/odatav4/internal/olingo/processor/CountEntityCollectionProcessor.java
@@ -88,6 +88,7 @@ public CountEntityCollectionProcessor(Vertx vertx, RoutingContext routingContext
 
     @Override
     public void init(OData odata, ServiceMetadata serviceMetadata) {
+        super.init(odata, serviceMetadata);
         this.odata = odata;
         this.serviceMetadata = serviceMetadata;
     }

diff --git a/src/main/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/EntityProcessor.java b/src/main/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/EntityProcessor.java
@@ -151,6 +151,7 @@ static Entity findEntityByKeyPredicates(RoutingContext routingContext, UriResour
 
     @Override
     public void init(OData odata, ServiceMetadata serviceMetadata) {
+        super.init(odata, serviceMetadata);
         this.odata = odata;
         this.serviceMetadata = serviceMetadata;
     }

diff --git a/src/main/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/PrimitiveProcessor.java b/src/main/java/io/neonbee/endpoint/odatav4/internal/olingo/processor/PrimitiveProcessor.java
@@ -54,6 +54,7 @@ public PrimitiveProcessor(Vertx vertx, RoutingContext routingContext, Promise<Vo
 
     @Override
     public void init(OData odata, ServiceMetadata serviceMetadata) {
+        super.init(odata, serviceMetadata);
         this.odata = odata;
         this.serviceMetadata = serviceMetadata;
     }