Skip to content

Commit

Permalink
=remote Clean up unused field.
Browse files Browse the repository at this point in the history
  • Loading branch information
He-Pin committed Sep 9, 2023
1 parent e9ab2cc commit d0099a1
Showing 1 changed file with 1 addition and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
package org.apache.pekko.remote.transport.netty

import java.net.{ InetAddress, InetSocketAddress, SocketAddress }
import java.util.concurrent.{ CancellationException, ConcurrentHashMap, Executors }
import java.util.concurrent.{ CancellationException, Executors }
import java.util.concurrent.atomic.AtomicInteger

import scala.annotation.nowarn
Expand Down Expand Up @@ -358,11 +358,6 @@ class NettyTransport(val settings: NettyTransportSettings, val system: ExtendedA

private val log = Logging.withMarker(system, classOf[NettyTransport])

/**
* INTERNAL API
*/
private[netty] final val udpConnectionTable = new ConcurrentHashMap[SocketAddress, HandleEventListener]()

private def createExecutorService() =
UseDispatcherForIo.map(system.dispatchers.lookup).getOrElse(Executors.newCachedThreadPool(system.threadFactory))

Expand Down

0 comments on commit d0099a1

Please sign in to comment.