这是来自https://github.com/eigengo/activator-spray-twitter/blob/master/src/main/scala/core/tweetstream.scala的代码
什么〜>(波浪号箭头)运算符呢?我认为必须是HttpRequest的运营商,但我在喷涂API中找不到这样的运算符.
我可以计算出该授权是它返回一个函数(HttpRequest的=>的HttpRequest),所以VAL RQ必须是一个的HttpRequest其返回由授权返回的函数施加后的值.
def receive: Receive = {
case query: String =>
val body = HttpEntity(ContentType(MediaTypes.`application/x-www-form-urlencoded`), s"track=$query")
val rq = HttpRequest(HttpMethods.POST, uri = uri, entity = body) ~> authorize
sendTo(io).withResponsesReceivedBy(self)(rq)
case ChunkedResponseStart(_) =>
case MessageChunk(entity, _) => TweetUnmarshaller(entity).fold(_ => (), processor !)
case _ =>
}
Run Code Online (Sandbox Code Playgroud)
提前致谢!
| 归档时间: |
|
| 查看次数: |
3225 次 |
| 最近记录: |