gistfile1.txt

/**
   * Wait for new notification socket
	 */
	def waitForNotification = WebSocket.using[JsValue] { request =>
  	  	val iteratee = Promise[Iteratee[JsValue, Unit]]()
  	  
  	  	val enumerator = Concurrent.unicast[JsValue](onStart = { clientChannel =>
  	  		iteratee.success(Iteratee.foreach[JsValue] {
  	  			json => {
  	  				Logger.debug("== Enumerator called ==")
  	  				Logger.debug("json: " + json.toString)
        		  
  	  				val action = (json \ "action").as[String]
  	  				val data = (json \ "data").as[JsValue]
  	  				
  	  				Logger.debug(">> action: " + action)
  	  				executeAction(action, data, clientChannel)
  	  			}
  	  		}.mapDone {
  	  			_ => {
  	  				Logger.debug("disconnected client channel")
  	  				NotificationActor.disconnect(clientChannel)
  	  			}
  	  		})
  	  	})

  	  	(Iteratee.flatten(iteratee.future), enumerator)
	}