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

Removing more boilerplate from AkkaServlet

Browse source
This commit is contained in:
Viktor Klang 2010-10-05 14:41:09 +02:00
parent 44903557ed
commit d3ffd4155f
1 changed files with 3 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-http/src/main/scala/AkkaCometServlet.scala
View file

@ -61,7 +61,7 @@ class AkkaServlet extends AtmosphereServlet {
* Provide a fallback for default values
*/
override def getInitParameter(key : String) =
Option(super.getInitParameter(key)).getOrElse(initParams.get(key))
Option(super.getInitParameter(key)).getOrElse(initParams get key)
/*
* Provide a fallback for default values
@ -89,15 +89,13 @@ class AkkaServlet extends AtmosphereServlet {
addAtmosphereHandler("/*", servlet, new AkkaBroadcaster)
}
lazy val akkaCometResolver: CometSupportResolver = new DefaultCometSupportResolver(config) {
override lazy val createCometSupportResolver: CometSupportResolver = new DefaultCometSupportResolver(config) {
import scala.collection.JavaConversions._
lazy val desiredCometSupport =
Option(getInitParameter("cometSupport")) filter testClassExists map newCometSupport
Option(AkkaServlet.this.getInitParameter("cometSupport")) filter testClassExists map newCometSupport
override def resolve(useNativeIfPossible : Boolean, useBlockingAsDefault : Boolean) : CometSupport[_ <: AtmosphereResource[_,_]] =
desiredCometSupport.getOrElse(super.resolve(useNativeIfPossible, useBlockingAsDefault))
}
override def createCometSupportResolver() = akkaCometResolver
}