cleanups examples

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

Author: OlegDokuka

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/channel/ChannelEchoClient.java

@@ -43,9 +43,7 @@ public static void main(String[] args) {
                     .map(s -> "Echo: " + s)
                     .map(DefaultPayload::create));
 
-    RSocketServer.create(echoAcceptor)
-        .bind(TcpServerTransport.create("localhost", 7000))
-        .subscribe();
+    RSocketServer.create(echoAcceptor).bindNow(TcpServerTransport.create("localhost", 7000));
 
     RSocket socket =
         RSocketConnector.connectWith(TcpClientTransport.create("localhost", 7000)).block();

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/client/RSocketClientExample.java

@@ -34,7 +34,7 @@ public static void main(String[] args) {
         .bind(TcpServerTransport.create("localhost", 7000))
         .delaySubscription(Duration.ofSeconds(5))
         .doOnNext(cc -> logger.info("Server started on the address : {}", cc.address()))
-        .subscribe();
+        .block();
 
     Mono<RSocket> source =
         RSocketConnector.create()

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/plugins/LimitRateInterceptorExample.java

@@ -39,8 +39,7 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
                   }
                 }))
         .interceptors(registry -> registry.forResponder(LimitRateInterceptor.forResponder(64)))
-        .bind(TcpServerTransport.create("localhost", 7000))
-        .subscribe();
+        .bindNow(TcpServerTransport.create("localhost", 7000));
 
     RSocket socket =
         RSocketConnector.create()

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/requestresponse/HelloWorldClient.java

@@ -50,8 +50,7 @@ public Mono<Payload> requestResponse(Payload p) {
         };
 
     RSocketServer.create(SocketAcceptor.with(rsocket))
-        .bind(TcpServerTransport.create("localhost", 7000))
-        .subscribe();
+        .bindNow(TcpServerTransport.create("localhost", 7000));
 
     RSocket socket =
         RSocketConnector.connectWith(TcpClientTransport.create("localhost", 7000)).block();

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/resume/ResumeFileTransfer.java

@@ -66,8 +66,7 @@ public static void main(String[] args) {
                           .log("server");
                     }))
             .resume(resume)
-            .bind(TcpServerTransport.create("localhost", 8000))
-            .block();
+            .bindNow(TcpServerTransport.create("localhost", 8000));
 
     RSocket client =
         RSocketConnector.create()

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/stream/ClientStreamingToServer.java

@@ -16,12 +16,13 @@
 
 package io.rsocket.examples.transport.tcp.stream;
 
+import io.rsocket.Payload;
 import io.rsocket.RSocket;
 import io.rsocket.SocketAcceptor;
 import io.rsocket.core.RSocketConnector;
 import io.rsocket.core.RSocketServer;
 import io.rsocket.transport.netty.client.TcpClientTransport;
-import io.rsocket.transport.netty.server.WebsocketServerTransport;
+import io.rsocket.transport.netty.server.TcpServerTransport;
 import io.rsocket.util.DefaultPayload;
 import java.time.Duration;
 import org.slf4j.Logger;
@@ -38,21 +39,24 @@ public static void main(String[] args) throws InterruptedException {
                 payload ->
                     Flux.interval(Duration.ofMillis(100))
                         .map(aLong -> DefaultPayload.create("Interval: " + aLong))))
-        .bind(WebsocketServerTransport.create("localhost", 7000))
-        .subscribe();
+        .bindNow(TcpServerTransport.create("localhost", 7000));
 
     RSocket socket =
-        RSocketConnector.connectWith(TcpClientTransport.create("localhost", 7000)).block();
-
-    //    socket
-    //        .requestStream(DefaultPayload.create("Hello"))
-    //        .map(Payload::getDataUtf8)
-    //        .doOnNext(logger::debug)
-    //        .take(10)
-    //        .then()
-    //        .doFinally(signalType -> socket.dispose())
-    //        .then()
-    //        .block();
+        RSocketConnector.create()
+            .setupPayload(DefaultPayload.create("test", "test"))
+            .connect(TcpClientTransport.create("localhost", 7000))
+            .block();
+
+    final Payload payload = DefaultPayload.create("Hello");
+    socket
+        .requestStream(payload)
+        .map(Payload::getDataUtf8)
+        .doOnNext(logger::debug)
+        .take(10)
+        .then()
+        .doFinally(signalType -> socket.dispose())
+        .then()
+        .block();
 
     Thread.sleep(1000000);
   }

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/stream/ServerStreamingToClient.java

@@ -43,8 +43,7 @@ public static void main(String[] args) {
 
               return Mono.just(new RSocket() {});
             })
-        .bind(TcpServerTransport.create("localhost", 7000))
-        .subscribe();
+        .bindNow(TcpServerTransport.create("localhost", 7000));
 
     RSocket rsocket =
         RSocketConnector.create()