scala - WebSocket 操作调用在运行时被忽略

Question

慧极客。我正在为我的项目中的实时通知模块进行编码。我很想从函数中调用 WebSocket Action 方法，以通过连接将通知数据传递给客户端。
这是我的代码..

def liveNotification(data: String) = WebSocket.using[JsValue] { implicit request  =>
    val iteratee = Iteratee.ignore[JsValue]
    val enumerator =  Enumerator[JsValue](Json.toJson(data))
    (iteratee,enumerator)
}

def createNotification(notificationTo: BigInteger, notiParams:Tuple5[String,String,BigInteger,BigInteger,BigInteger]) = {       
    val retData = NotificationModel.createNotification(notificationTo,notiParams)
    val strData = write(retData)
    liveNotification(strData)
}

问题是“liveNotification()”调用被简单地忽略了。请帮助我提出我做错了什么的任何建议？

Answer 1

确保使用 Json 值调用它，至少是一个空对象。解析器只会匹配它识别为 Json 的东西。