socialnetworknews

commit 08560c8df31e8a035ec23871aea1501714c7b8fa
parent 62252265e5ba741dd394f613debf8ea0799e4335
Author: MTRNord <mtrnord1@gmail.com>
Date:   Sun,  4 Feb 2018 01:21:12 +0100

Fix typo

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

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

2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/scala/Main.scala b/src/main/scala/Main.scala
@@ -36,7 +36,7 @@ object Main extends App {
       //sender.sendHelloWorld
 
       val stream = new twitterCrawler.StreamingApi(streamingClient = streamingClient, restClient = restClient)
-      stream.fetchHastags
+      stream.fetchHashtags
 
       webServer.WebServer.main()
     case Failure(err) => println(err.toString)
diff --git a/src/main/scala/twitterCrawler/StreamingApi.scala b/src/main/scala/twitterCrawler/StreamingApi.scala
@@ -12,7 +12,7 @@ import scala.concurrent.{Await, Future}
 
 class StreamingApi (val streamingClient: TwitterStreamingClient, val restClient: TwitterRestClient) {
   val conf: Config = ConfigFactory.load()
-  def fetchHastags: Future[TwitterStream] = {
+  def fetchHashtags: Future[TwitterStream] = {
     val trackedWords: Seq[String] = conf.getStringList("twitter.trackedWords").asScala
     val trackedLists: List[String] = conf.getStringList("twitter.lists").asScala.toList
     val trackedUsers: Seq[Long] = Await.result(this.getListUsers(trackedLists), scala.concurrent.duration.Duration.Inf)