Forgot equals.

streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala

@@ -61,7 +61,7 @@ object SocketReceiver  {
   def bytesToLines(inputStream: InputStream): Iterator[String] = {
     val dataInputStream = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"))
     new NextIterator[String] {
-      protected override def getNext() {
+      protected override def getNext() = {
         val nextValue = dataInputStream.readLine()
         if (nextValue == null) {
           finished = true