Skip to content

Commit

Permalink
Fix deprecation in NettyRSocketServerFactoryTests
Browse files Browse the repository at this point in the history
  • Loading branch information
dreis2211 authored and mbhave committed Jun 11, 2020
1 parent fc3c5c8 commit 469dfc2
Showing 1 changed file with 1 addition and 2 deletions.
Expand Up @@ -22,7 +22,6 @@
import java.util.concurrent.Callable;

import io.netty.buffer.PooledByteBufAllocator;
import io.rsocket.AbstractRSocket;
import io.rsocket.ConnectionSetupPayload;
import io.rsocket.Payload;
import io.rsocket.RSocket;
Expand Down Expand Up @@ -202,7 +201,7 @@ static class EchoRequestResponseAcceptor implements SocketAcceptor {

@Override
public Mono<RSocket> accept(ConnectionSetupPayload setupPayload, RSocket rSocket) {
return Mono.just(new AbstractRSocket() {
return Mono.just(new RSocket() {
@Override
public Mono<Payload> requestResponse(Payload payload) {
return Mono.just(DefaultPayload.create(payload));
Expand Down

0 comments on commit 469dfc2

Please sign in to comment.