Cleanup

beacon/src/main/java/io/xpipe/beacon/exchange/MessageExchanges.java

@@ -15,7 +15,10 @@ public class MessageExchanges {
     private static void loadAll() {
         if (ALL == null) {
             ALL = ServiceLoader.load(MessageExchange.class).stream()
-                    .map(ServiceLoader.Provider::get)
+                    .map(s -> {
+                        var ex = (MessageExchange) s.get();
+                        return ex;
+                    })
                     .collect(Collectors.toSet());
         }
     }

beacon/src/main/java/io/xpipe/beacon/exchange/ReadExecuteExchange.java

@@ -1,36 +0,0 @@
-package io.xpipe.beacon.exchange;
-
-import io.xpipe.beacon.RequestMessage;
-import io.xpipe.beacon.ResponseMessage;
-import io.xpipe.core.source.DataSourceId;
-import io.xpipe.core.store.DataStore;
-import lombok.Builder;
-import lombok.NonNull;
-import lombok.Value;
-import lombok.extern.jackson.Jacksonized;
-
-/**
- * Sends stream-based data to a daemon.
- */
-public class ReadExecuteExchange implements MessageExchange {
-
-    @Override
-    public String getId() {
-        return "readExecute";
-    }
-
-    @Jacksonized
-    @Builder
-    @Value
-    public static class Request implements RequestMessage {
-        @NonNull
-        DataStore dataStore;
-
-        DataSourceId target;
-    }
-
-    @Jacksonized
-    @Builder
-    @Value
-    public static class Response implements ResponseMessage {}
-}

beacon/src/main/java/module-info.java

@@ -55,7 +55,6 @@ module io.xpipe.beacon {
             SelectExchange,
             ReadExchange,
             QueryTextDataExchange,
-            ReadExecuteExchange,
             ListStoresExchange,
             DialogExchange,
             QueryDataSourceExchange,