diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java index 25645ce001585e4cdef9e1d35c796ecf43d1c171..37f26a9d582de44e7e0813481b86373b3d5c35dd 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java @@ -16,21 +16,21 @@ package org.springframework.http.server.reactive; -import io.netty.buffer.ByteBuf; +import java.util.function.Function; + import reactor.core.publisher.Mono; -import reactor.io.ipc.ChannelHandler; import reactor.io.netty.http.HttpChannel; import org.springframework.core.io.buffer.NettyDataBufferFactory; import org.springframework.util.Assert; /** - * Adapt {@link HttpHandler} to the Reactor Netty {@link ChannelHandler}. + * Adapt {@link HttpHandler} to the Reactor Netty channel handling function. * * @author Stephane Maldini * @since 5.0 */ -public class ReactorHttpHandlerAdapter implements ChannelHandler { +public class ReactorHttpHandlerAdapter implements Function> { private final HttpHandler httpHandler;