|
|
|
@ -1,5 +1,5 @@
|
|
|
|
|
/*
|
|
|
|
|
* Copyright 2012-2020 the original author or authors.
|
|
|
|
|
* Copyright 2012-2021 the original author or authors.
|
|
|
|
|
*
|
|
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
|
* you may not use this file except in compliance with the License.
|
|
|
|
@ -54,7 +54,6 @@ import org.springframework.messaging.rsocket.RSocketStrategies;
|
|
|
|
|
import org.springframework.util.SocketUtils;
|
|
|
|
|
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat;
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
|
|
|
|
|
import static org.mockito.ArgumentMatchers.any;
|
|
|
|
|
import static org.mockito.BDDMockito.will;
|
|
|
|
|
import static org.mockito.Mockito.inOrder;
|
|
|
|
@ -203,7 +202,7 @@ class NettyRSocketServerFactoryTests {
|
|
|
|
|
String payload = "test payload";
|
|
|
|
|
Mono<String> responseMono = this.requester.route("test").data(payload).retrieveMono(String.class);
|
|
|
|
|
StepVerifier.create(responseMono)
|
|
|
|
|
.verifyErrorSatisfies((ex) -> assertThatExceptionOfType(ClosedChannelException.class));
|
|
|
|
|
.verifyErrorSatisfies((ex) -> assertThat(ex).isInstanceOf(ClosedChannelException.class));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private RSocketRequester createRSocketTcpClient() {
|
|
|
|
|