Merge branch 'release/1.3.1'

Author: mostroverkhov

README.md

@@ -7,83 +7,95 @@
 
 ![RSocket-JVM implementations](readme/impls_stripe.png)
 
-## TL;DR
+Very fast GRPC-like & GRPC-compatible services on JVM with rich streaming models over multiple data-center and internet transports [[1]](https://jauntsdn.com/mstreams/).
 
->lean & very fast GRPC-like [services](https://github.com/jauntsdn/rsocket-jvm-interop-examples/tree/feature/oss/jaunt-rsocket-reactor-service/src/generated/main/rsocketRpc/trisocket) on JVM with rich streaming model;
-> 
->multiple APIs: CompletableFuture; streaming with reactor, rxjava, mutiny, helidon;
+## Summary
+
+>multiple APIs: CompletableFuture; traditional streaming with GRPC-API (StreamObserver), or flavor of reactive: smallrye-mutiny, rxjava, reactor;
 > 
->pluggable networking: tcp, unix sockets, grpc, websockets-over-http2;
+>pluggable networking: TCP, unix sockets, GRPC, websockets, websockets-over-http2;
 > 
->service APIs / codegen stubs (Message-Streams) are split from library runtime (including network transports, load estimators, metrics);
+>service APIs / RPC codegen stubs (Message-Streams) are split from library runtime (RSocket-JVM, including network transports, load estimators, metrics);
 > 
 >transparent origin (RPC) & proxy load estimation which enables cpu-efficient load balancers;
 > 
 >native image support with graalvm
 
-RSocket-JVM is [very fast](https://jauntsdn.com/post/rsocket-summary/) (millions of messages per core with each interaction) alternative to 
+`RSocket-JVM` is [very fast](https://jauntsdn.com/post/rsocket-summary/) (millions of messages per core with each interaction) alternative to 
 projectreactor-only RSocket/RSocket-java from "Reactive Foundation" -
 which is plagued by number of performance and security [problems](https://jauntsdn.com/post/rsocket-vs-spring/).
 
-RSocket is low latency/high throughput L5 network protocol 
-intended for high-performance services communication. It is transport agnostic, and runs on top 
-of any reliable byte stream transport.
-
-This repository hosts Message-Streams - API part of RSocket-JVM, suite of libraries for fast interprocess/network communication using CompletableFutures & major
-Reactive Streams implementations.  
+This repository hosts `Message-Streams` - API part of `RSocket-JVM`: suite of libraries for interprocess/network communication over 
+multiple transports using multiple APIs.  
 
-RSocket-JVM includes RSocket-RPC: remote procedure call system on top of Protocol Buffers.
+`Message-Streams` includes RPC: code-generation based remote procedure call system on top of Protocol Buffers.
 
-### CompletableFuture, project-reactor, rxjava, helidon, smallrye-mutiny
+RSocket is low latency/high throughput L5 network protocol intended for high-performance services communication. 
+It is transport agnostic, and runs on top of any reliable byte stream transport.
 
-RSocket-JVM is currently comprised of RSocket-futures(CompletableFuture), RSocket-rxjava (rxjava3), RSocket-reactor (project-reactor), RSocket-helidon (helidon-commons-reactive)
-and smallrye-mutiny (mutiny).
+### CompletableFuture; GRPC StreamObserver; smallrye-mutiny, rxjava, project-reactor
 
 **Multiple vendor libraries**. [Shared protocol core](https://jauntsdn.com/post/rsocket-jvm/) with minimal dependencies 
-(netty-buffer only) streamline development process for each next vendor library.   
-  
-**Non-intrusive**. API ([MessageStreams](https://github.com/jauntsdn/rsocket-jvm/blob/1.1.4/rsocket-reactor/src/main/java/com/jauntsdn/rsocket/MessageStreams.java)) & runtime ([RSocket](https://github.com/jauntsdn/rsocket-jvm/blob/1.1.4/rsocket-reactor/src/main/java/com/jauntsdn/rsocket/RSocket.java)) are clearly split so from end-user perspective there is 
-only defined set of basic interactions on buffers/messages:
+(`netty-buffer` only) streamlined development process for each vendor library & reduced maintenance cost of multiple libraries to feasible level.
+
+Project supports 3 kinds of APIs: 
+* request-response with RSocket-futures (JDK only CompletableFuture); 
+* traditional streaming with RSocket-GRPC (GRPC-stubs StreamObserver); 
+* flavors of reactive with RSocket-mutiny (smallrye-mutiny), RSocket-rxjava (rxjava3), and RSocket-reactor (project-reactor).
+
+**GRPC compatible**. All implementations are directly compatible with GRPC via MessageStreams-RPC & GRPC transport.
+GRPC clients can access such services without separate "gateway" binaries and IDL sharing schemes.
+ 
+**Non-intrusive**. [MessageStreams](https://github.com/jauntsdn/rsocket-jvm/blob/1.3.0/rsocket-reactor/src/main/java/com/jauntsdn/rsocket/MessageStreams.java) API & [RSocket-JVM](https://github.com/jauntsdn/rsocket-jvm/blob/1.3.0/rsocket-reactor/src/main/java/com/jauntsdn/rsocket/RSocket.java) runtime are clearly split so from end-user perspective there is 
+only set of streaming & non-streaming interactions on buffers/messages:
+
+```groovy
+  void requestResponse(Message message, StreamObserver<Message> responseObserver);
+  void requestStream(Message message, StreamObserver<Message> responseObserver);
+  StreamObserver<Message> requestChannel(StreamObserver<Message> responseObserver);
+  void fireAndForget(Message message, StreamObserver<Message> responseObserver);
+```
+
 ```groovy
   Publisher<Message> requestResponse(Message message);
   Publisher<Message> requestStream(Message message);
   Publisher<Message> requestChannel(Publisher<Message> messages);
   Publisher<Void> fireAndForget(Message message);
 ```
 
-**GRPC compatible**. All implementations are directly compatible with GRPC via RSocket-RPC & GRPC transport.
-GRPC clients can access such services without separate "gateway" binaries and awkward IDL sharing schemes.
+### RPC 
 
-### Shared transports
+[MessageStreams-RPC](https://jauntsdn.com/post/rsocket-grpc/) is reflection-free, codegen based remote procedure call system 
+relying on single data format - protocol buffers. This combination opened many optimization opportunities and enabled 
+GRPC interop via respective GRPC transport.
+
+Each vendor library has RPC module accompanied by compiler binary.
 
-Message transports are based on `netty` only so usable by each vendor library, and are considered part 
-of (not yet publicly available) RSocket-JVM runtime.
+### Multiple network transports
 
-Currently they are comprised of 
+Network transports are based on `Netty` only for compatibility with each vendor library, and are part of RSocket-JVM runtime.
 
-* `TCP` & `UNIX domain sockets` - known efficient byte stream protocols for datacenter / inter-process communication,
+Currently comprised of 
+
+* `TCP` & `UNIX domain sockets` - known efficient byte stream protocols for datacenter / inter-process communication;
 
 and Http2 streams based transports for interop:
 
 * `GRPC-RSocket-RPC` for communication with internet clients / external services;
 
-* `Websocket-over-http2` for cross-cloud communication with Internet Standards transport.
-
-### RSocket-RPC 
+* `WebSocket` & `Websocket-over-http2` for cross-cloud communication with Internet Standards transport.
 
-[RSocket-RPC](https://jauntsdn.com/post/rsocket-grpc/) is reflection-free, codegen based remote procedure call system 
-relying on single data format - protocol buffers. This combination opened many optimization opportunities and enabled 
-GRPC interop via respective GRPC transport.
+### Examples
 
-Each vendor library has RSocket-RPC API module accompanied by compiler binary.
+[messagestreams-interop-examples](https://github.com/jauntsdn/messagestreams-grpc-interop-examples) demonstrate all implementations interop.
 
-### Examples
+[messagestreams-grpc-examples](https://github.com/jauntsdn/messagestreams-grpc-examples) demonstrate GRPC-stub StreamObserver based services.
 
-[RSocket-jvm-interop-examples](https://github.com/jauntsdn/rsocket-jvm-interop-examples).
+[messagestreams-futures-examples](https://github.com/jauntsdn/messagestreams-futures-examples) demonstrate jdk CompletableFuture based services.
 
 ## Build
 
-Building `jauntsdn/RSocket-jvm` requires java11 for helidon, and java8 for rxjava/reactor/mutiny. 
+Building `jauntsdn/RSocket-jvm` requires java11+ (for helidon-commons-reactive), while the rest (futures/grpc-stubs/rxjava/reactor/mutiny) are java8+. 
 ```
 ./gradlew
 ```
@@ -95,7 +107,7 @@ Building & installing artifacts into local maven repository
 
 ## Binaries
 
-Binary releases are published on Maven Central for java futures (CompletableFuture), reactor, rxjava, helidon & mutiny libraries.
+Binary releases are published on Maven Central for grpc, futures (CompletableFuture), reactor, rxjava, helidon & mutiny libraries.
 
 ```groovy
 
@@ -104,29 +116,29 @@ repositories {
 }
 
 dependencies {
-    implementation "com.jauntsdn.rsocket:rsocket-messages:1.1.4"
-    implementation "com.jauntsdn.rsocket:rsocket-rpc-idl:1.1.4"
-    implementation "com.jauntsdn.rsocket:rsocket-<VENDOR>:1.1.4"
-    implementation "com.jauntsdn.rsocket:rsocket-rpc-<VENDOR>:1.1.4"
+    implementation "com.jauntsdn.rsocket:rsocket-messages:1.3.0"
+    implementation "com.jauntsdn.rsocket:rsocket-rpc-idl:1.3.0"
+    implementation "com.jauntsdn.rsocket:rsocket-<VENDOR>:1.3.0"
+    implementation "com.jauntsdn.rsocket:rsocket-rpc-<VENDOR>:1.3.0"
 }
 ```
 
-RSocket-RPC compiler binaries are linux, windows(x86) only
+MessageStreams-RPC compiler binaries are linux, windows(x86) only
 ```groovy
 protobuf {
      plugins {
           rsocketRpc {
-              artifact = "com.jauntsdn.rsocket:rsocket-rpc-<VENDOR>-compiler:1.1.4"
+              artifact = "com.jauntsdn.rsocket:rsocket-rpc-<VENDOR>-compiler:1.3.0"
           }
      }
 }
 ```
 
 ### Message streams. Design goals & scope
 
-**Fast transparent networking with practically useful set of reactive streams libraries, solely for JVM serverside applications**
+**Fast transparent networking with practically useful set of streams libraries, solely for JVM serverside applications**
 
-Currently rxjava3, projectreactor, smallrye-mutiny, helidon-reactive-streams.
+Currently CompletableFuture, GRPC-stubs (StreamObserver), smallrye-mutiny, rxjava3, projectreactor.
 
 Languages and platforms other than JVM lack framework ecosystem (and most lack single reactive streams compatible library),
 so there are no substantial (except populist) reasons for commitment.   
@@ -149,7 +161,7 @@ is essential for JVM-only Message Streams (RSocket-JVM) libraries.
 
 Transports are shared, and considered part of runtime due to tight contract with RSocket-JVM for performance reasons. 
 This project offers strictly few highly optimized transports for interprocess/datacenter (TCP, UNIX sockets) 
-and cross-datacenter (GRPC-RSocketRPC, websocket-over-htp2) communication, instead of user-friendly APIs for
+and cross-datacenter (GRPC-RSocketRPC, websocket, websocket-over-htp2) communication, instead of user-friendly APIs for
 external implementors. This way if supported transports are extended or replaced, transport contract
 is free to change to accommodate new needs.   
 

gradle.properties

@@ -1,13 +1,13 @@
 group=com.jauntsdn.rsocket
-version=1.3.0
+version=1.3.1
 
 dependencyManagementPluginVersion=1.1.0
 protobufPluginVersion=0.9.2
 googleJavaFormatPluginVersion=0.9
 gitPluginVersion=0.13.0
 versionsPluginVersion=0.45.0
 
-nettyBomVersion=4.1.89.Final
+nettyBomVersion=4.1.90.Final
 grpcStubVersion=1.53.0
 reactorBomVersion=Dysprosium-SR22
 rxjavaVersion=3.1.6
@@ -19,7 +19,7 @@ javaxAnnotationVersion=1.3.2
 jakartaInjectVersion=2.0.1
 jakartaAnnotationVersion=2.1.1
 
-protobufVersion=3.22.0
+protobufVersion=3.22.2
 
 release=false
 org.gradle.parallel=true

rsocket-bom/gradle.lockfile

@@ -1,6 +1,6 @@
 # This is a Gradle generated file for dependency locking.
 # Manual edits can break the build and are not advised.
 # This file is expected to be part of source control.
-io.netty:netty-bom:4.1.89.Final=classpath
+io.netty:netty-bom:4.1.90.Final=classpath
 io.projectreactor:reactor-bom:Dysprosium-SR22=classpath
 empty=

rsocket-futures/gradle.lockfile

@@ -7,7 +7,7 @@ com.google.errorprone:javac-shaded:9+181-r4173-1=googleJavaFormat1.6
 com.google.googlejavaformat:google-java-format:1.6=googleJavaFormat1.6
 com.google.guava:guava:22.0=googleJavaFormat1.6
 com.google.j2objc:j2objc-annotations:1.1=googleJavaFormat1.6
-io.netty:netty-buffer:4.1.89.Final=compileClasspath,runtimeClasspath
-io.netty:netty-common:4.1.89.Final=compileClasspath,runtimeClasspath
+io.netty:netty-buffer:4.1.90.Final=compileClasspath,runtimeClasspath
+io.netty:netty-common:4.1.90.Final=compileClasspath,runtimeClasspath
 org.codehaus.mojo:animal-sniffer-annotations:1.14=googleJavaFormat1.6
 empty=annotationProcessor

rsocket-grpc/build.gradle

@@ -10,7 +10,10 @@ plugins {
 
 dependencies {
     api project(":rsocket-messages")
-    api "io.grpc:grpc-stub"
+    api ("io.grpc:grpc-stub") {
+        exclude group: "com.google.guava", module: "guava"
+        exclude group: "com.google.errorprone", module: "error_prone_annotations"
+    }
 
     compileOnly "com.google.code.findbugs:jsr305"
 }

rsocket-grpc/gradle.lockfile

@@ -3,20 +3,14 @@
 # This file is expected to be part of source control.
 com.google.code.findbugs:jsr305:3.0.2=compileClasspath,googleJavaFormat1.6,runtimeClasspath
 com.google.errorprone:error_prone_annotations:2.0.18=googleJavaFormat1.6
-com.google.errorprone:error_prone_annotations:2.14.0=compileClasspath,runtimeClasspath
 com.google.errorprone:javac-shaded:9+181-r4173-1=googleJavaFormat1.6
 com.google.googlejavaformat:google-java-format:1.6=googleJavaFormat1.6
-com.google.guava:failureaccess:1.0.1=compileClasspath,runtimeClasspath
 com.google.guava:guava:22.0=googleJavaFormat1.6
-com.google.guava:guava:31.1-android=compileClasspath,runtimeClasspath
-com.google.guava:listenablefuture:9999.0-empty-to-avoid-conflict-with-guava=compileClasspath,runtimeClasspath
 com.google.j2objc:j2objc-annotations:1.1=googleJavaFormat1.6
-com.google.j2objc:j2objc-annotations:1.3=compileClasspath,runtimeClasspath
 io.grpc:grpc-api:1.53.0=compileClasspath,runtimeClasspath
 io.grpc:grpc-context:1.53.0=compileClasspath,runtimeClasspath
 io.grpc:grpc-stub:1.53.0=compileClasspath,runtimeClasspath
-io.netty:netty-buffer:4.1.89.Final=compileClasspath,runtimeClasspath
-io.netty:netty-common:4.1.89.Final=compileClasspath,runtimeClasspath
-org.checkerframework:checker-qual:3.12.0=compileClasspath,runtimeClasspath
+io.netty:netty-buffer:4.1.90.Final=compileClasspath,runtimeClasspath
+io.netty:netty-common:4.1.90.Final=compileClasspath,runtimeClasspath
 org.codehaus.mojo:animal-sniffer-annotations:1.14=googleJavaFormat1.6
 empty=annotationProcessor

rsocket-grpc/src/main/java/com/jauntsdn/rsocket/AbstractRSocket.java

@@ -25,7 +25,7 @@
 import java.util.concurrent.CompletionStage;
 import javax.annotation.Nullable;
 
-public abstract class AbstractRSocket implements RSocket {
+public abstract class AbstractRSocket implements RSocketHandler {
 
   @Override
   public void metadataPush(Message message, StreamObserver<Message> responseObserver) {
@@ -57,6 +57,14 @@ public StreamObserver<Message> requestChannel(StreamObserver<Message> responseOb
     return MessageStreamsHandler.noopServerObserver();
   }
 
+  @Override
+  public StreamObserver<Message> requestChannel(
+      Message message, StreamObserver<Message> responseObserver) {
+    message.release();
+    responseObserver.onError(new UnsupportedOperationException("request-channel not implemented"));
+    return MessageStreamsHandler.noopServerObserver();
+  }
+
   @Override
   public void dispose() {}
 

rsocket-helidon/gradle.lockfile

@@ -11,8 +11,8 @@ io.helidon.common:helidon-common-mapper:2.5.6=compileClasspath,runtimeClasspath
 io.helidon.common:helidon-common-reactive:2.5.6=compileClasspath,runtimeClasspath
 io.helidon.common:helidon-common-service-loader:2.5.6=compileClasspath,runtimeClasspath
 io.helidon.common:helidon-common:2.5.6=compileClasspath,runtimeClasspath
-io.netty:netty-buffer:4.1.89.Final=compileClasspath,runtimeClasspath
-io.netty:netty-common:4.1.89.Final=compileClasspath,runtimeClasspath
+io.netty:netty-buffer:4.1.90.Final=compileClasspath,runtimeClasspath
+io.netty:netty-common:4.1.90.Final=compileClasspath,runtimeClasspath
 jakarta.annotation:jakarta.annotation-api:1.3.5=compileClasspath,runtimeClasspath
 org.codehaus.mojo:animal-sniffer-annotations:1.14=googleJavaFormat1.6
 empty=annotationProcessor

rsocket-messages/gradle.lockfile

@@ -7,7 +7,7 @@ com.google.errorprone:javac-shaded:9+181-r4173-1=googleJavaFormat1.6
 com.google.googlejavaformat:google-java-format:1.6=googleJavaFormat1.6
 com.google.guava:guava:22.0=googleJavaFormat1.6
 com.google.j2objc:j2objc-annotations:1.1=googleJavaFormat1.6
-io.netty:netty-buffer:4.1.89.Final=compileClasspath,runtimeClasspath
-io.netty:netty-common:4.1.89.Final=compileClasspath,runtimeClasspath
+io.netty:netty-buffer:4.1.90.Final=compileClasspath,runtimeClasspath
+io.netty:netty-common:4.1.90.Final=compileClasspath,runtimeClasspath
 org.codehaus.mojo:animal-sniffer-annotations:1.14=googleJavaFormat1.6
 empty=annotationProcessor

rsocket-mutiny/gradle.lockfile

@@ -7,8 +7,8 @@ com.google.errorprone:javac-shaded:9+181-r4173-1=googleJavaFormat1.6
 com.google.googlejavaformat:google-java-format:1.6=googleJavaFormat1.6
 com.google.guava:guava:22.0=googleJavaFormat1.6
 com.google.j2objc:j2objc-annotations:1.1=googleJavaFormat1.6
-io.netty:netty-buffer:4.1.89.Final=compileClasspath,runtimeClasspath
-io.netty:netty-common:4.1.89.Final=compileClasspath,runtimeClasspath
+io.netty:netty-buffer:4.1.90.Final=compileClasspath,runtimeClasspath
+io.netty:netty-common:4.1.90.Final=compileClasspath,runtimeClasspath
 io.smallrye.common:smallrye-common-annotation:1.13.0=compileClasspath,runtimeClasspath
 io.smallrye.reactive:mutiny:1.8.0=compileClasspath,runtimeClasspath
 org.codehaus.mojo:animal-sniffer-annotations:1.14=googleJavaFormat1.6