changed receivers from var to val

apache · Feb 8, 2016 · 06273fc · 06273fc
1 parent 8d579f1
commit 06273fc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala
@@ -39,7 +39,7 @@ case class UnsubscribeReceiver(receiverActor: ActorRef)
 class FeederActor extends Actor {
 
   val rand = new Random()
-  var receivers: ArrayBuffer[ActorRef] = new ArrayBuffer[ActorRef]()
+  val receivers = new ArrayBuffer[ActorRef]()
 
   val strings: Array[String] = Array("words ", "may ", "count ")
 
@@ -67,7 +67,7 @@ class FeederActor extends Actor {
 
     case UnsubscribeReceiver(receiverActor: ActorRef) =>
       println("received unsubscribe from %s".format(receiverActor.toString))
-      receivers = receivers.dropWhile(x => x eq receiverActor)
+      receivers.dropWhile(x => x eq receiverActor)
   }
 }