fix: #565 batch requests issue

src/main/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;
@@ -19,6 +21,8 @@
 public abstract class AsynchronousProcessor implements Processor {
     private static final String PROCESSING_STACK = "processingStack";
 
+    private static final Promise<Void> INITIAL_STATE = null;
+
     protected Vertx vertx;
 
     protected RoutingContext routingContext;
@@ -90,4 +94,29 @@ private static Deque<List<Future<Void>>> processingStack() {
         }
         return processingStack;
     }
+
+    /**
+     * Resets the {@code subProcessPromise} to {@code null}.
+     * <p>
+     * This method is used to release any references held by the {@code subProcessPromise}, ensuring that the processor
+     * starts with a clean state. It is intentionally set to {@code null} as part of the processor's lifecycle
+     * management.
+     */
+    private void resetSubProcessPromise() {
+        subProcessPromise = INITIAL_STATE; // Intentional reset to null
+    }
+
+    /**
+     * Initializes the processor by resetting its internal state.
+     * <p>
+     * This method is called during the processor's initialization phase. It uses {@link #resetSubProcessPromise()} to
+     * ensure the {@code subProcessPromise} is cleared, preparing the processor for a new lifecycle.
+     *
+     * @param odata           the OData instance for this processor
+     * @param serviceMetadata the metadata for the OData service
+     */
+    @Override
+    public void init(OData odata, ServiceMetadata serviceMetadata) {
+        resetSubProcessPromise();
+    }
 }

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;
     }
 

src/main/java/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;
     }

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;
     }

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;
     }