Correct outdated error message

This commit is contained in:
Rossen Stoyanchev 2020-10-23 17:04:44 +01:00
parent c524849774
commit 51fb49be34
1 changed files with 1 additions and 2 deletions

View File

@ -177,8 +177,7 @@ class MessagingRSocket implements RSocket {
}
})
.thenMany(Flux.defer(() -> responseRef.get() != null ?
responseRef.get() :
Mono.error(new IllegalStateException("Something went wrong: reply Mono not set"))));
responseRef.get() : Mono.error(new IllegalStateException("Expected response"))));
}
private DataBuffer retainDataAndReleasePayload(Payload payload) {