From 6524d28f69d8f32bec8a1292326cabb9271bc404 Mon Sep 17 00:00:00 2001 From: Maksym Ostroverkhov Date: Wed, 6 Mar 2024 13:40:39 +0200 Subject: [PATCH] rsocket-helidon: deprecate for removal since helidon-common-reactive project seems inactive/abandoned. (#14) --- .../main/java/com/jauntsdn/rsocket/AbstractRSocket.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/ClientAcceptor.java | 2 ++ .../java/com/jauntsdn/rsocket/ClientStreamsAcceptor.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/Closeable.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/MessageStreams.java | 7 ++++++- .../java/com/jauntsdn/rsocket/MessageStreamsHandler.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/RSocket.java | 5 ++++- .../src/main/java/com/jauntsdn/rsocket/RSocketHandler.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/RSocketProxy.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/ServerAcceptor.java | 2 ++ .../java/com/jauntsdn/rsocket/ServerStreamsAcceptor.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/RpcHandler.java | 7 ++++++- .../main/java/com/jauntsdn/rsocket/RpcInstrumentation.java | 2 ++ .../src/main/java/com/jauntsdn/rsocket/RpcService.java | 2 ++ 14 files changed, 38 insertions(+), 3 deletions(-) diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/AbstractRSocket.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/AbstractRSocket.java index 5f134b7..6f2a133 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/AbstractRSocket.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/AbstractRSocket.java @@ -20,6 +20,8 @@ import io.helidon.common.reactive.Single; import java.util.concurrent.Flow; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public abstract class AbstractRSocket implements RSocketHandler { @Override diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientAcceptor.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientAcceptor.java index c967b1d..e823f1d 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientAcceptor.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientAcceptor.java @@ -18,6 +18,8 @@ import java.util.function.Function; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface ClientAcceptor { RSocket accept(SetupMessage setup, RSocket requesterRSocket); diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientStreamsAcceptor.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientStreamsAcceptor.java index 7e6c47c..757dd53 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientStreamsAcceptor.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ClientStreamsAcceptor.java @@ -16,6 +16,8 @@ package com.jauntsdn.rsocket; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface ClientStreamsAcceptor { MessageStreams accept(SetupMessage setup, MessageStreams requester); diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/Closeable.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/Closeable.java index ab9b6ba..1b30fc6 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/Closeable.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/Closeable.java @@ -18,6 +18,8 @@ import io.helidon.common.reactive.Single; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface Closeable extends GracefulCloseable { Single onClose(); diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreams.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreams.java index 93286eb..aa8c5e9 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreams.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreams.java @@ -23,7 +23,12 @@ import java.util.concurrent.Flow; import java.util.concurrent.ScheduledExecutorService; -/** Channel interactions for async exchange of binary messages using Helidon-common-reactive API. */ +/** + * Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. + * + *

Channel interactions for async exchange of binary messages using Helidon-common-reactive API. + */ +@Deprecated public interface MessageStreams extends Closeable { /** diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreamsHandler.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreamsHandler.java index e7d3bb9..5246f30 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreamsHandler.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/MessageStreamsHandler.java @@ -19,6 +19,8 @@ import io.helidon.common.reactive.Multi; import java.util.concurrent.Flow; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface MessageStreamsHandler extends MessageStreams { default Multi requestChannel(Message message, Flow.Publisher messages) { diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocket.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocket.java index cc106b4..58c6cea 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocket.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocket.java @@ -22,9 +22,12 @@ import java.util.function.Function; /** - * Models RSocket interactions as described in + * Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. + * + *

Models RSocket interactions as described in * https://github.com/rsocket/rsocket/blob/master/Protocol.md#stream-sequences-and-lifetimes */ +@Deprecated public interface RSocket extends MessageStreams, Availability { /** diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketHandler.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketHandler.java index 016f1cd..7f440c8 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketHandler.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketHandler.java @@ -16,4 +16,6 @@ package com.jauntsdn.rsocket; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface RSocketHandler extends RSocket, MessageStreamsHandler {} diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketProxy.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketProxy.java index 0103662..87564af 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketProxy.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/RSocketProxy.java @@ -23,6 +23,8 @@ import java.util.concurrent.Flow; import java.util.concurrent.ScheduledExecutorService; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public class RSocketProxy implements RSocket, RSocketHandler { protected final MessageStreams source; diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerAcceptor.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerAcceptor.java index 8d4c48b..268cc3d 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerAcceptor.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerAcceptor.java @@ -19,6 +19,8 @@ import io.helidon.common.reactive.Single; import java.util.function.Function; +/** Deprecated for removal since helidon-common-reactive project seems to be inactive/abandoned. */ +@Deprecated public interface ServerAcceptor { Single accept(SetupMessage setup, RSocket requesterRSocket); diff --git a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerStreamsAcceptor.java b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerStreamsAcceptor.java index 93bc402..9bc2b08 100644 --- a/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerStreamsAcceptor.java +++ b/rsocket-helidon/src/main/java/com/jauntsdn/rsocket/ServerStreamsAcceptor.java @@ -18,6 +18,8 @@ import io.helidon.common.reactive.Single; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface ServerStreamsAcceptor { Single accept(SetupMessage setup, MessageStreams requester); diff --git a/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcHandler.java b/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcHandler.java index a2d9de7..0ad491a 100644 --- a/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcHandler.java +++ b/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcHandler.java @@ -30,7 +30,12 @@ import java.util.function.Consumer; import javax.annotation.Nullable; -/** Utility for serving multiple {@link RpcService} from single {@link MessageStreams} endpoint. */ +/** + * Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. + * + *

Utility for serving multiple {@link RpcService} from single {@link MessageStreams} endpoint. + */ +@Deprecated public final class RpcHandler implements MessageStreamsHandler { private static final String NO_DEFAULT_ZERO_SERVICES_MESSAGE = "RpcHandler: no default service because 0 services registered"; diff --git a/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcInstrumentation.java b/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcInstrumentation.java index 6950bef..df2fdf7 100644 --- a/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcInstrumentation.java +++ b/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcInstrumentation.java @@ -20,6 +20,8 @@ import java.util.concurrent.Flow; import java.util.function.Function; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface RpcInstrumentation { Function, ? extends Flow.Publisher> instrumentMulti( diff --git a/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcService.java b/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcService.java index 061acf0..fb24db8 100644 --- a/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcService.java +++ b/rsocket-rpc-helidon/src/main/java/com/jauntsdn/rsocket/RpcService.java @@ -16,6 +16,8 @@ package com.jauntsdn.rsocket; +/** Deprecated for removal since helidon-common-reactive project seems inactive/abandoned. */ +@Deprecated public interface RpcService extends MessageStreamsHandler { String service();