1
我正在學習Iteratee和相關的API,以滿足我的流式推文流傳輸要求之一。使用Play 2.1和Scala 2.10。是否遵循使用Iteratee的最佳方式,這也會產生將鳴叫保存到MongoDB的結果?玩這個用例的Iteratee
val wsStream = new Enumerator[Array[Byte]] {
def apply[A](iteratee: Iteratee[Array[Byte], A]) = {
WS.url("https://stream.twitter.com/1.1/statuses/filter.json?track=" + term)
.sign(OAuthCalculator(Twitter.KEY, tokens))
.get(_ => iteratee)
}
}
wsStream.apply(Iteratee.foreach(bytes => saveTweetToMongo(bytes)))