log.txt

> run
[info] Running main
[info] Pooling...
[info] [INFO] [01/05/2017 20:19:26.965] [default-akka.actor.default-dispatcher-2] [akka.actor.ActorSystemImpl(default)] HttpMethod(GET) https://stream.twitter.com/1.1/statuses/sample.json?language=ja&stall_warnings=false

twitter4s-example.scala

import akka.actor.{ActorSystem}
import com.danielasfregola.twitter4s.entities.enums.Language
import com.danielasfregola.twitter4s.{TwitterStreamingClient}
import com.danielasfregola.twitter4s.entities.{Tweet}

object main {
  def main(args: Array[String]): Unit = {
    implicit val system = ActorSystem()
    
    val streamingClient = TwitterStreamingClient()
    streamingClient.sampleStatuses(Seq(Language.Japanese)) {
      case tweet: Tweet => println(tweet.text)
    }
    
    println("Pooling...")
    if (io.StdIn.readLine != null) {
      println("Shutdown")
      system.terminate()
    }
  }
}