wip

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

Author: OlegDokuka

rsocket-core/src/test/java/io/rsocket/core/DefaultRSocketClientTests.java

@@ -491,6 +491,10 @@ public Mono<Void> onClose() {
 
     onCloseDelayer.tryEmitEmpty();
 
+    onCloseSubscriber.assertNotTerminated();
+
+    rule.otherClosedSink.tryEmitEmpty();
+
     onCloseSubscriber.assertTerminated().assertComplete();
 
     Assertions.assertThat(rule.socket.isDisposed()).isTrue();
@@ -512,6 +516,10 @@ public void shouldResolveOnStartSource() {
 
     rule.client.onClose().subscribe(assertSubscriber1);
 
+    assertSubscriber1.assertNotTerminated();
+
+    rule.otherClosedSink.tryEmitEmpty();
+
     assertSubscriber1.assertTerminated().assertComplete();
 
     Assertions.assertThat(rule.socket.isDisposed()).isTrue();