|
|
|
@ -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"); |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* you may not use this file except in compliance with 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 org.springframework.util.SocketUtils; |
|
|
|
|
|
|
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat; |
|
|
|
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.ArgumentMatchers.any; |
|
|
|
import static org.mockito.BDDMockito.will; |
|
|
|
import static org.mockito.BDDMockito.will; |
|
|
|
import static org.mockito.Mockito.inOrder; |
|
|
|
import static org.mockito.Mockito.inOrder; |
|
|
|
@ -203,7 +202,7 @@ class NettyRSocketServerFactoryTests { |
|
|
|
String payload = "test payload"; |
|
|
|
String payload = "test payload"; |
|
|
|
Mono<String> responseMono = this.requester.route("test").data(payload).retrieveMono(String.class); |
|
|
|
Mono<String> responseMono = this.requester.route("test").data(payload).retrieveMono(String.class); |
|
|
|
StepVerifier.create(responseMono) |
|
|
|
StepVerifier.create(responseMono) |
|
|
|
.verifyErrorSatisfies((ex) -> assertThatExceptionOfType(ClosedChannelException.class)); |
|
|
|
.verifyErrorSatisfies((ex) -> assertThat(ex).isInstanceOf(ClosedChannelException.class)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private RSocketRequester createRSocketTcpClient() { |
|
|
|
private RSocketRequester createRSocketTcpClient() { |
|
|
|
|