Adapt to changed naming in Netty 5

reactor · May 28, 2024 · 65cd7fe · 65cd7fe
1 parent f558812
commit 65cd7fe
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/reactor-netty5-core/src/main/java/reactor/netty5/resources/DefaultLoopEpoll.java b/reactor-netty5-core/src/main/java/reactor/netty5/resources/DefaultLoopEpoll.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2011-2022 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2011-2024 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -25,7 +25,7 @@
 import io.netty5.channel.ServerChannel;
 import io.netty5.channel.epoll.Epoll;
 import io.netty5.channel.epoll.EpollDatagramChannel;
-import io.netty5.channel.epoll.EpollHandler;
+import io.netty5.channel.epoll.EpollIoHandler;
 import io.netty5.channel.epoll.EpollServerSocketChannel;
 import io.netty5.channel.epoll.EpollSocketChannel;
 import io.netty5.channel.socket.DatagramChannel;
@@ -78,7 +78,7 @@ public <SERVERCHANNEL extends ServerChannel> SERVERCHANNEL getServerChannel(Clas
 
 	@Override
 	public EventLoopGroup newEventLoopGroup(int threads, ThreadFactory factory) {
-		return new MultithreadEventLoopGroup(threads, factory, EpollHandler.newFactory());
+		return new MultithreadEventLoopGroup(threads, factory, EpollIoHandler.newFactory());
 	}
 
 	static final Logger log = Loggers.getLogger(DefaultLoopEpoll.class);

diff --git a/reactor-netty5-core/src/main/java/reactor/netty5/resources/DefaultLoopIOUring.java b/reactor-netty5-core/src/main/java/reactor/netty5/resources/DefaultLoopIOUring.java
@@ -25,7 +25,7 @@
 import io.netty5.channel.socket.SocketChannel;
 import io.netty5.channel.uring.IOUring;
 import io.netty5.channel.uring.IOUringDatagramChannel;
-import io.netty5.channel.uring.IOUringHandler;
+import io.netty5.channel.uring.IOUringIoHandler;
 import io.netty5.channel.uring.IOUringServerSocketChannel;
 import io.netty5.channel.uring.IOUringSocketChannel;
 import reactor.util.Logger;
@@ -79,7 +79,7 @@ public <SERVERCHANNEL extends ServerChannel> SERVERCHANNEL getServerChannel(Clas
 
 	@Override
 	public EventLoopGroup newEventLoopGroup(int threads, ThreadFactory factory) {
-		return new MultithreadEventLoopGroup(threads, factory, IOUringHandler.newFactory());
+		return new MultithreadEventLoopGroup(threads, factory, IOUringIoHandler.newFactory());
 	}
 
 	static final Logger log = Loggers.getLogger(DefaultLoopIOUring.class);

diff --git a/reactor-netty5-core/src/main/java/reactor/netty5/resources/DefaultLoopKQueue.java b/reactor-netty5-core/src/main/java/reactor/netty5/resources/DefaultLoopKQueue.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2018-2022 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2018-2024 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -25,7 +25,7 @@
 import io.netty5.channel.ServerChannel;
 import io.netty5.channel.kqueue.KQueue;
 import io.netty5.channel.kqueue.KQueueDatagramChannel;
-import io.netty5.channel.kqueue.KQueueHandler;
+import io.netty5.channel.kqueue.KQueueIoHandler;
 import io.netty5.channel.kqueue.KQueueServerSocketChannel;
 import io.netty5.channel.kqueue.KQueueSocketChannel;
 import io.netty5.channel.socket.DatagramChannel;
@@ -77,7 +77,7 @@ public <SERVERCHANNEL extends ServerChannel> SERVERCHANNEL getServerChannel(Clas
 
 	@Override
 	public EventLoopGroup newEventLoopGroup(int threads, ThreadFactory factory) {
-		return new MultithreadEventLoopGroup(threads, factory, KQueueHandler.newFactory());
+		return new MultithreadEventLoopGroup(threads, factory, KQueueIoHandler.newFactory());
 	}
 
 	static final Logger log = Loggers.getLogger(DefaultLoopKQueue.class);