fix: compile errors

Author: paullatzelsperger

extensions/data-plane/data-plane-azure-data-factory/src/main/java/org/eclipse/edc/connector/dataplane/azure/datafactory/AzureDataFactoryTransferManager.java

@@ -78,7 +78,7 @@ public AzureDataFactoryTransferManager(
      * @param request the data flow request.
      * @return a {@link CompletableFuture} that completes when the data transfer completes.
      */
-    public CompletableFuture<StreamResult<Void>> transfer(DataFlowRequest request) {
+    public CompletableFuture<StreamResult<Object>> transfer(DataFlowRequest request) {
 
         PipelineResource pipeline = pipelineFactory.createPipeline(request);
 
@@ -108,7 +108,7 @@ public CompletableFuture<StreamResult<Void>> transfer(DataFlowRequest request) {
     }
 
     @NotNull
-    private CompletableFuture<StreamResult<Void>> awaitRunCompletion(String runId) {
+    private CompletableFuture<StreamResult<Object>> awaitRunCompletion(String runId) {
         monitor.debug("Awaiting ADF pipeline completion for run " + runId);
 
         var timeout = clock.instant().plus(maxDuration);
@@ -142,7 +142,7 @@ private CompletableFuture<StreamResult<Void>> awaitRunCompletion(String runId) {
         return completedFuture(StreamResult.error("ADF run timed out"));
     }
 
-    private StreamResult<Void> complete(String accountName, String containerName, String sharedAccessSignature) {
+    private StreamResult<Object> complete(String accountName, String containerName, String sharedAccessSignature) {
         try {
             // Write an empty blob to indicate completion
             blobStoreApi.getBlobAdapter(accountName, containerName, COMPLETE_BLOB_NAME, new AzureSasCredential(sharedAccessSignature))

extensions/data-plane/data-plane-azure-data-factory/src/main/java/org/eclipse/edc/connector/dataplane/azure/datafactory/AzureDataFactoryTransferService.java

@@ -46,7 +46,7 @@ public boolean canHandle(DataFlowRequest request) {
     }
 
     @Override
-    public CompletableFuture<StreamResult<Void>> transfer(DataFlowRequest request) {
+    public CompletableFuture<StreamResult<Object>> transfer(DataFlowRequest request) {
         return transferManager.transfer(request);
     }
 

extensions/data-plane/data-plane-azure-data-factory/src/test/java/org/eclipse/edc/connector/dataplane/azure/datafactory/AzureDataFactoryTransferManagerTest.java

@@ -171,7 +171,7 @@ void transfer_timeout() {
         verify(client).cancelPipelineRun(runId);
     }
 
-    ObjectAssert<StreamResult<Void>> assertThatTransferResult() {
+    ObjectAssert<StreamResult<Object>> assertThatTransferResult() {
         return assertThat(transferManager.transfer(request))
                 .succeedsWithin(Duration.ofMinutes(1));
     }

extensions/data-plane/data-plane-azure-data-factory/src/test/java/org/eclipse/edc/connector/dataplane/azure/datafactory/AzureDataFactoryTransferServiceTest.java

@@ -41,10 +41,10 @@ class AzureDataFactoryTransferServiceTest {
     private final Result<Boolean> failure = Result.failure("Test Failure");
     private final Result<Boolean> success = Result.success(true);
     @SuppressWarnings("unchecked")
-    private final CompletableFuture<StreamResult<Void>> result = mock(CompletableFuture.class);
+    private final CompletableFuture<StreamResult<Object>> result = mock(CompletableFuture.class);
 
     @ParameterizedTest
-    @ValueSource(booleans = { true, false })
+    @ValueSource(booleans = {true, false})
     void canHandle_onResult(boolean expected) {
         // Arrange
         when(validator.canHandle(request.build())).thenReturn(expected);

extensions/data-plane/data-plane-azure-storage/src/main/java/org/eclipse/edc/connector/dataplane/azure/storage/pipeline/AzureStorageDataSink.java

@@ -38,11 +38,14 @@ public class AzureStorageDataSink extends ParallelSink {
     private String sharedAccessSignature;
     private BlobStoreApi blobStoreApi;
 
+    private AzureStorageDataSink() {
+    }
+
     /**
      * Writes data into an Azure storage container.
      */
     @Override
-    protected StreamResult<Void> transferParts(List<DataSource.Part> parts) {
+    protected StreamResult<Object> transferParts(List<DataSource.Part> parts) {
         for (DataSource.Part part : parts) {
             String blobName = part.name();
             try (var input = part.openStream()) {
@@ -64,7 +67,7 @@ protected StreamResult<Void> transferParts(List<DataSource.Part> parts) {
     }
 
     @Override
-    protected StreamResult<Void> complete() {
+    protected StreamResult<Object> complete() {
         try {
             // Write an empty blob to indicate completion
             blobStoreApi.getBlobAdapter(accountName, containerName, COMPLETE_BLOB_NAME, new AzureSasCredential(sharedAccessSignature))
@@ -76,17 +79,18 @@ protected StreamResult<Void> complete() {
     }
 
     @NotNull
-    private StreamResult<Void> getTransferResult(Exception e, String logMessage, Object... args) {
+    private StreamResult<Object> getTransferResult(Exception e, String logMessage, Object... args) {
         String message = format(logMessage, args);
         monitor.severe(message, e);
         return StreamResult.error(message);
     }
 
-    private AzureStorageDataSink() {
-    }
-
     public static class Builder extends ParallelSink.Builder<Builder, AzureStorageDataSink> {
 
+        private Builder() {
+            super(new AzureStorageDataSink());
+        }
+
         public static Builder newInstance() {
             return new Builder();
         }
@@ -118,9 +122,5 @@ protected void validate() {
             Objects.requireNonNull(sink.sharedAccessSignature, "sharedAccessSignature");
             Objects.requireNonNull(sink.blobStoreApi, "blobStoreApi");
         }
-
-        private Builder() {
-            super(new AzureStorageDataSink());
-        }
     }
 }