provides RSocketClient interface

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/RSocketClient.java

@@ -0,0 +1,65 @@
+package io.rsocket;
+
+import org.reactivestreams.Publisher;
+import reactor.core.Disposable;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * A client-side interface to simplify interactions with the {@link
+ * io.rsocket.core.RSocketConnector}
+ *
+ * @since 1.0.1
+ */
+public interface RSocketClient extends Disposable {
+
+  /**
+   * Provides access to the source {@link RSocket} used by this {@link RSocketClient}
+   *
+   * @return returns a {@link Mono} which returns the source {@link RSocket}
+   */
+  Mono<RSocket> source();
+
+  /**
+   * Fire and Forget interaction model of {@link RSocketClient}.
+   *
+   * @param payloadMono Request payload as {@link Mono}.
+   * @return {@code Publisher} that completes when the passed {@code payload} is successfully
+   *     handled, otherwise errors.
+   */
+  Mono<Void> fireAndForget(Mono<Payload> payloadMono);
+
+  /**
+   * Request-Response interaction model of {@link RSocketClient}.
+   *
+   * @param payloadMono Request payload as {@link Mono}.
+   * @return {@code Publisher} containing at most a single {@code Payload} representing the
+   *     response.
+   */
+  Mono<Payload> requestResponse(Mono<Payload> payloadMono);
+
+  /**
+   * Request-Stream interaction model of {@link RSocketClient}.
+   *
+   * @param payloadMono Request payload as {@link Mono}.
+   * @return {@code Publisher} containing the stream of {@code Payload}s representing the response.
+   */
+  Flux<Payload> requestStream(Mono<Payload> payloadMono);
+
+  /**
+   * Request-Channel interaction model of {@link RSocketClient}.
+   *
+   * @param payloads Stream of request payloads.
+   * @return Stream of response payloads.
+   */
+  Flux<Payload> requestChannel(Publisher<Payload> payloads);
+
+  /**
+   * Metadata-Push interaction model of {@link RSocketClient}.
+   *
+   * @param payloadMono Request payload as {@link Mono}.
+   * @return {@code Publisher} that completes when the passed {@code payload} is successfully
+   *     handled, otherwise errors.
+   */
+  Mono<Void> metadataPush(Mono<Payload> payloadMono);
+}