logs

Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
rsocket · Mar 28, 2023 · 02d166b · 02d166b
1 parent f2fe455
commit 02d166b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rsocket-test/src/main/java/io/rsocket/test/TransportTest.java b/rsocket-test/src/main/java/io/rsocket/test/TransportTest.java
@@ -728,9 +728,11 @@ public void sendErrorAndClose(RSocketErrorException e) {
       public Flux<ByteBuf> receive() {
         return duplexConnection
             .receive()
+            .doOnTerminate(() -> logger.info("[" + this + "] Receive is done before PO"))
             .subscribeOn(Schedulers.boundedElastic())
             .doOnNext(ByteBuf::retain)
             .publishOn(Schedulers.boundedElastic(), Integer.MAX_VALUE)
+            .doOnTerminate(() -> logger.info("[" + this + "] Receive is done after PO"))
             .doOnDiscard(ReferenceCounted.class, ReferenceCountUtil::safeRelease)
             .transform(
                 Operators.<ByteBuf, ByteBuf>lift(