socialnetworknews

commit 54f0efd4a5a215a07aa80f5c32cca258bbf184a2
parent e86ed87e8ffac1037c0af8eeb1f4ba3b62eb1035
Author: MTRNord <mtrnord1@gmail.com>
Date:   Sun,  4 Feb 2018 13:06:23 +0100

Scalafmt config

Signed-off-by: MTRNord <mtrnord1@gmail.com>

Diffstat:
M
src/main/scala/twitterCrawler/StreamingApi.scala
 | 
20
+++++++++++++-------

1 file changed, 13 insertions(+), 7 deletions(-)
diff --git a/src/main/scala/twitterCrawler/StreamingApi.scala b/src/main/scala/twitterCrawler/StreamingApi.scala
@@ -24,11 +24,13 @@ class StreamingApi(val streamingClient: TwitterStreamingClient,
       conf.getStringList("twitter.lists").asScala.toList
     val trackedUsers: Seq[Long] = Await.result(
       this.getListUsers(trackedLists),
-      scala.concurrent.duration.Duration.Inf)
+      scala.concurrent.duration.Duration.Inf
+    )
 
     println(
       s"Launching streaming session with tracked keywords: $trackedWords\r\n" +
-        s"And with tracked Users: $trackedUsers")
+        s"And with tracked Users: $trackedUsers"
+    )
 
     streamingClient.filterStatuses(tracks = trackedWords, follow = trackedUsers) {
       case tweet: Tweet =>
@@ -64,10 +66,13 @@ class StreamingApi(val streamingClient: TwitterStreamingClient,
         val slug = splitted(1)
 
         var listUsers = Await.result(
-          restClient.listMembersBySlugAndOwnerName(slug = slug,
-                                                   owner_screen_name = username,
-                                                   include_entities = false),
-          scala.concurrent.duration.Duration.Inf)
+          restClient.listMembersBySlugAndOwnerName(
+            slug = slug,
+            owner_screen_name = username,
+            include_entities = false
+          ),
+          scala.concurrent.duration.Duration.Inf
+        )
         listUsers.data.users.foreach((user: User) => {
           trackedUsers = trackedUsers :+ user.id
         })
@@ -77,7 +82,8 @@ class StreamingApi(val streamingClient: TwitterStreamingClient,
               slug = slug,
               owner_screen_name = username,
               include_entities = false,
-              cursor = listUsers.data.next_cursor),
+              cursor = listUsers.data.next_cursor
+            ),
             scala.concurrent.duration.Duration.Inf
           )
           listUsers.data.users.foreach((user: User) => {