logs

Signed-off-by: Oleh Dokuka <odokuka@vmware.com> Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com> Signed-off-by: OlegDokuka <odokuka@vmware.com>
rsocket · Mar 27, 2023 · 49eb695 · 49eb695
1 parent ce3e0bb
commit 49eb695
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 8 deletions.
diff --git a/...ansport-netty/src/test/java/io/rsocket/transport/netty/TcpFragmentationTransportTest.java b/...ansport-netty/src/test/java/io/rsocket/transport/netty/TcpFragmentationTransportTest.java
@@ -60,7 +60,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                             Flux.interval(Duration.ofSeconds(1))
                                 .doOnNext(
                                     __ -> channels.forEach(c -> logger.info("Active Channel " + c)))
-                                .takeUntilOther(ds.onDispose())
+                                .takeUntilOther(ds.onDispose().log("-disposing-"))
                                 .subscribe())
                     .doOnUnbound(
                         (ds) -> {

diff --git a/...t-transport-netty/src/test/java/io/rsocket/transport/netty/TcpResumableTransportTest.java b/...t-transport-netty/src/test/java/io/rsocket/transport/netty/TcpResumableTransportTest.java
@@ -61,7 +61,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                             Flux.interval(Duration.ofSeconds(1))
                                 .doOnNext(
                                     __ -> channels.forEach(c -> logger.info("Active Channel " + c)))
-                                .takeUntilOther(ds.onDispose())
+                                .takeUntilOther(ds.onDispose().log("-disposing-"))
                                 .subscribe())
                     .doOnUnbound(
                         (ds) -> {

diff --git a/.../src/test/java/io/rsocket/transport/netty/TcpResumableWithFragmentationTransportTest.java b/.../src/test/java/io/rsocket/transport/netty/TcpResumableWithFragmentationTransportTest.java
@@ -61,7 +61,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                             Flux.interval(Duration.ofSeconds(1))
                                 .doOnNext(
                                     __ -> channels.forEach(c -> logger.info("Active Channel " + c)))
-                                .takeUntilOther(ds.onDispose())
+                                .takeUntilOther(ds.onDispose().log("-disposing-"))
                                 .subscribe())
                     .doOnUnbound(
                         (ds) -> {

diff --git a/rsocket-transport-netty/src/test/java/io/rsocket/transport/netty/TcpSecureTransportTest.java b/rsocket-transport-netty/src/test/java/io/rsocket/transport/netty/TcpSecureTransportTest.java
@@ -56,7 +56,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                                   .doOnNext(
                                       __ ->
                                           channels.forEach(c -> logger.info("Active Channel " + c)))
-                                  .takeUntilOther(ds.onDispose())
+                                  .takeUntilOther(ds.onDispose().log("-disposing-"))
                                   .subscribe())
                       .doOnUnbound(
                           (ds) -> {

diff --git a/...sport-netty/src/test/java/io/rsocket/transport/netty/WebsocketResumableTransportTest.java b/...sport-netty/src/test/java/io/rsocket/transport/netty/WebsocketResumableTransportTest.java
@@ -63,7 +63,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                             Flux.interval(Duration.ofSeconds(1))
                                 .doOnNext(
                                     __ -> channels.forEach(c -> logger.info("Active Channel " + c)))
-                                .takeUntilOther(ds.onDispose())
+                                .takeUntilOther(ds.onDispose().log("-disposing-"))
                                 .subscribe())
                     .doOnUnbound(
                         (ds) -> {

diff --git a/...est/java/io/rsocket/transport/netty/WebsocketResumableWithFragmentationTransportTest.java b/...est/java/io/rsocket/transport/netty/WebsocketResumableWithFragmentationTransportTest.java
@@ -64,7 +64,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                             Flux.interval(Duration.ofSeconds(1))
                                 .doOnNext(
                                     __ -> channels.forEach(c -> logger.info("Active Channel " + c)))
-                                .takeUntilOther(ds.onDispose())
+                                .takeUntilOther(ds.onDispose().log("-disposing-"))
                                 .subscribe())
                     .doOnUnbound(
                         (ds) -> {

diff --git a/...ransport-netty/src/test/java/io/rsocket/transport/netty/WebsocketSecureTransportTest.java b/...ransport-netty/src/test/java/io/rsocket/transport/netty/WebsocketSecureTransportTest.java
@@ -82,7 +82,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                                   .doOnNext(
                                       __ ->
                                           channels.forEach(c -> logger.info("Active Channel " + c)))
-                                  .takeUntilOther(ds.onDispose())
+                                  .takeUntilOther(ds.onDispose().log("-disposing-"))
                                   .subscribe())
                       .doOnUnbound(
                           (ds) -> {

diff --git a/rsocket-transport-netty/src/test/java/io/rsocket/transport/netty/WebsocketTransportTest.java b/rsocket-transport-netty/src/test/java/io/rsocket/transport/netty/WebsocketTransportTest.java
@@ -63,7 +63,7 @@ static void cleanup() throws ExecutionException, InterruptedException, TimeoutEx
                             Flux.interval(Duration.ofSeconds(1))
                                 .doOnNext(
                                     __ -> channels.forEach(c -> logger.info("Active Channel " + c)))
-                                .takeUntilOther(ds.onDispose())
+                                .takeUntilOther(ds.onDispose().log("-disposing-"))
                                 .subscribe())
                     .doOnUnbound(
                         (ds) -> {