Play 2.1 - Using Concurrent.PatchPannel

usingPatchPannel.scala

def stream = WebSocket.using[JsValue] { req =>
  val out = Concurrent.patchPanel[JsValue] { patcher =>
      // callback called when the enumerator "out" is applied to an iteratee, here the
      // Websocket output Iteratee      
      patcher.patchIn(streamEnumerator1)
      // ...
      patcher.patchIn(streamEnumerator2)
  }

  val in = Iteratee.foreach[JsValue] { json =>
    val topic = // read json and get the topic that the user want to subscribe to
  } mapDone { _ => println("Disconnected") }

  (in, out)
}