fixes

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

Author: OlegDokuka

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

@@ -109,7 +109,7 @@ 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"))
+        .contextWrite(Context.of("tag", "requester " + connection))
         .subscribe(null, this::tryShutdown, this::tryShutdown);
     onGracefulShutdownDone.subscribe(null, null, connection::dispose);
 

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

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