We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1936e8c commit 5ed16d9Copy full SHA for 5ed16d9
rsocket-core/src/test/java/io/rsocket/resume/ClientRSocketSessionTest.java
@@ -457,7 +457,7 @@ void shouldTerminateConnectionOnIllegalStateInKeepAliveFrame() {
457
.typeOf(FrameType.ERROR)
458
.matches(ReferenceCounted::release);
459
460
- resumableDuplexConnection.onClose().as(StepVerifier::create).expectError().verify();
+ resumableDuplexConnection.onClose().as(StepVerifier::create).expectComplete().verify();
461
462
transport.alloc().assertHasNoLeaks();
463
} finally {
0 commit comments