在play框架中关闭twitter流连接
在play框架中关闭twitter流连接
提问于 2014-03-13 12:12:56
在下面的代码示例中，我使用Play 2.2WSAPI连接到twitter流API。我被困在试图找出如何断开与流一旦建立。有什么正确的方法来代替停止应用程序吗？任何帮助都将不胜感激。
def watchTweets(keywords : String) = Action { implicit request =>
Logger.debug(s"watchTweets invoked with: $keywords")
val (tweetsOut, tweetChanel) = Concurrent.broadcast[JsValue]
WS.url(s"https://stream.twitter.com/1.1/statuses/filter.json?track=" + URLEncoder.encode(keywords, "UTF-8"))
.sign(OAuthCalculator(Twitter.KEY, Twitter.sessionTokenPair.get))
.postAndRetrieveStream("")(headers => Iteratee.foreach[Array[Byte]] { ba =>
val msg = new String(ba, "UTF-8")
Logger.debug(s"received message: $msg")
val tweet = Json.parse(msg)
tweetChanel.push(tweet)
}).flatMap(_.run)
Ok.chunked(tweetsOut &> Comet(callback = "parent.cometMessage")) }回答 1
Stack Overflow用户
回答已采纳
发布于 2014-03-13 13:25:34
这是一个众所周知的问题..。答案是您关闭了连接，但问题是，枚举器在尝试向客户端提供一条tweet之前不会注意到连接已关闭，而这种情况在它收到来自Twitter的另一条Twitter消息之前不会发生，这可能需要很长时间才能实现。
在进行Twitter流时，这当然是个问题，因为Twitter一次只允许用户创建一个流，因此这实际上意味着在第一个流接收到一些数据之前，您无法执行第二个流。
不幸的是，我们还没有一个工作，但我们正在考虑引入一个新的更低级别的流媒体API发挥在2.4的时间线，这肯定会允许这一点。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/22389866
复制
相似问题
在javascript中，应该在函数的顶部声明对象属性吗？
在C++中，应该在相应的头中声明局部变量吗？
应该在C++中内联声明函数的时间
当成员变量被构造函数参数初始化时，应该在声明中初始化它吗？
多行声明风格背后的原因？
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
