raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

make listener a val, remove other lazy vals

Browse source
This commit is contained in:
Ivan Porto Carrero 2012-01-19 12:50:51 +01:00
parent 69ace98b78
commit 6bdffd94a9
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-zeromq/src/main/scala/akka/zeromq/ConcurrentSocketActor.scala
View file

@ -158,8 +158,8 @@ private[zeromq] class ConcurrentSocketActor(params: Seq[SocketOption]) extends A
override def postStop {
try {
poller.unregister(socket)
currentPoll foreach { _ complete Right(Closing) }
poller.unregister(socket)
if (socket != null) socket.close
} finally {
notifyListener(Closed)
@ -181,12 +181,12 @@ private[zeromq] class ConcurrentSocketActor(params: Seq[SocketOption]) extends A
if (currentPoll.isEmpty) currentPoll = newEventLoop
}
private lazy val eventLoopDispatcher = {
private val eventLoopDispatcher = {
val fromConfig = params collectFirst { case PollDispatcher(name) ⇒ context.system.dispatchers.lookup(name) }
fromConfig getOrElse context.system.dispatcher
}
private lazy val pollTimeout = {
private val pollTimeout = {
val fromConfig = params collectFirst { case PollTimeoutDuration(duration) ⇒ duration }
fromConfig getOrElse 100.millis
}
@ -214,7 +214,7 @@ private[zeromq] class ConcurrentSocketActor(params: Seq[SocketOption]) extends A
receiveBytes(socket.recv(0))
}
private def listenerOpt = params collectFirst { case Listener(l) ⇒ l }
private val listenerOpt = params collectFirst { case Listener(l) ⇒ l }
private def watchListener() {
listenerOpt foreach context.watch
}