|
|
@ -198,7 +198,6 @@ class NettyRSocketServerFactoryTests {
|
|
|
|
static class EchoRequestResponseAcceptor implements SocketAcceptor {
|
|
|
|
static class EchoRequestResponseAcceptor implements SocketAcceptor {
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
@SuppressWarnings("deprecation")
|
|
|
|
|
|
|
|
public Mono<RSocket> accept(ConnectionSetupPayload setupPayload, RSocket rSocket) {
|
|
|
|
public Mono<RSocket> accept(ConnectionSetupPayload setupPayload, RSocket rSocket) {
|
|
|
|
return Mono.just(new RSocket() {
|
|
|
|
return Mono.just(new RSocket() {
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|