Netty based Listener

gistfile1.scala

case class Netty3Listener[In, Out](
  pipelineFactory: ChannelPipelineFactory,
  channelFactory: ServerChannelFactory
  bootstrapOptions: Map[String, Object], ... // stats/timeouts/ssl config
) extends Listener[In, Out] {
    def newServerPipelineFactory(
      statsReceiver: StatsReceiver, newBridge: () => ChannelHandler
    ) = new ChannelPipelineFactory { // #1
      def getPipeline() = {
        val pipeline = pipelineFactory.getPipeline()
        // ... add stats/timeouts/ssl
        pipeline.addLast("finagleBridge", newBridge()) // #2
          pipeline 
        }
      }
    def listen(addr: SocketAddress)( 
      serveTransport: Transport[In, Out] => Unit
    ): ListeningServer =
      new ListeningServer with CloseAwaitably {
        val newBridge = () => new ServerBridge(serveTransport, ...)
        val bootstrap = new ServerBootstrap(channelFactory)
        bootstrap.setOptions(bootstrapOptions.asJava)
        bootstrap.setPipelineFactory(
          newServerPipelineFactory(scopedStatsReceiver, newBridge))
        val ch = bootstrap.bind(addr)
        } 
      }
    }
// #1 Create a new ChannelPipelineFactory 
// #2 Add the Bridge into the ChannelPipeline