fixes

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

Author: OlegDokuka

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

@@ -109,7 +109,8 @@ class RSocketRequester extends RequesterResponderSupport implements RSocket {
     // DO NOT Change the order here. The Send processor must be subscribed to before receiving
     connection
         .onClose()
-        .contextWrite(Context.of("tag", "requester " + connection))
+        .contextWrite(Context.of("tag", "requester"))
+        .log("requester " + connection)
         .subscribe(null, this::tryShutdown, this::tryShutdown);
     onGracefulShutdownDone.subscribe(null, null, connection::dispose);
 

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

@@ -95,6 +95,7 @@ class RSocketResponder extends RequesterResponderSupport implements RSocket {
     connection
         .onClose()
         .contextWrite(Context.of("tag", "responder " + connection))
+        .log("responder " + connection)
         .subscribe(null, this::tryTerminateOnConnectionError, this::tryTerminateOnConnectionClose);
 
     onRequesterGracefulShutdownStarted.subscribe(null, null, this::onGracefulShutdownStarted);