Allow to disable native transport

Author: MukjepScarlet

src/main/kotlin/net/ccbluex/netty/http/HttpServer.kt

@@ -65,13 +65,14 @@ class HttpServer {
      * Starts the Netty server on the specified port.
      *
      * @param port The port of HTTP server. `0` means to auto select one.
+     * @param useNativeTransport Whether to use native transport (Epoll or KQueue).
      *
      * @return actual port of server.
      */
-    fun start(port: Int): Int = lock.withLock {
+    fun start(port: Int, useNativeTransport: Boolean = true): Int = lock.withLock {
         val b = ServerBootstrap()
 
-        val groups = TransportType.apply(b)
+        val groups = TransportType.apply(b, useNativeTransport)
         bossGroup = groups.first
         workerGroup = groups.second
 

src/main/kotlin/net/ccbluex/netty/http/util/TransportDetector.kt

@@ -20,6 +20,7 @@
 package net.ccbluex.netty.http.util
 
 import io.netty.bootstrap.ServerBootstrap
+import io.netty.channel.ChannelFactory
 import io.netty.channel.EventLoopGroup
 import io.netty.channel.ServerChannel
 import io.netty.channel.epoll.EpollEventLoopGroup
@@ -81,13 +82,17 @@ internal sealed interface TransportType {
          * Set the channel factory and event loop groups for the given server bootstrap.
          *
          * @param bootstrap The server bootstrap to configure.
+         * @param useNativeTransport Whether to use native transport (Epoll or KQueue).
+         *
          * @return Parent and child group.
          */
-        fun apply(bootstrap: ServerBootstrap): Pair<EventLoopGroup, EventLoopGroup> {
-            val parentGroup = available.newParentGroup()
-            val childGroup = available.newChildGroup()
+        fun apply(bootstrap: ServerBootstrap, useNativeTransport: Boolean): Pair<EventLoopGroup, EventLoopGroup> {
+            val type = if (useNativeTransport) available else Nio
+
+            val parentGroup = type.newParentGroup()
+            val childGroup = type.newChildGroup()
             bootstrap.group(parentGroup, childGroup)
-                .channelFactory(available::newServerChannel)
+                .channelFactory(ChannelFactory(type::newServerChannel))
             return parentGroup to childGroup
         }
     }