0

こんにちは、私は Twitter ストリーミング API に接続するアプリを作成しており、WS を使用してこのような接続を行っています。

WS.url(endpoint).withTimeout(-1).sign(OAuthCalculator(consumerKey, accessToken)).postAndRetrieveStream(parameters)(processResponse(_))

def processResponse(headers: ResponseHeaders) = {
   Iteratee.foreach[Array[Byte]] { chunk =>
     val chunkString = new String(chunk, "UTF-8")
     println(chunkString)
   }
}

接続が Twitter によって閉じられたかどうかを検出する方法があるかどうかを知りたい

ありがとう!

4

1 に答える 1