wip

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

Author: OlegDokuka

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

@@ -579,6 +579,8 @@ public void shouldBeRestartedIfSourceWasClosed() {
 
     rule.client.dispose();
 
+    rule.otherClosedSink.tryEmitEmpty();
+
     terminateSubscriber.assertTerminated().assertComplete();
 
     Assertions.assertThat(rule.client.connect()).isFalse();
@@ -634,6 +636,8 @@ public void shouldStartOriginalSourceOnceIfRacing() {
 
       rule.client.dispose();
 
+      rule.otherClosedSink.tryEmitEmpty();
+
       Assertions.assertThat(rule.client.isDisposed()).isTrue();
       Assertions.assertThat(rule.socket.isDisposed()).isTrue();