diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
index 95f32f0ca0f4d..16a6879192b32 100644
--- a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
+++ b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
@@ -146,10 +146,10 @@ class StreamingListenerSuite extends TestSuiteBase with Matchers {
         classOf[ReceiverInfoCollector].getName)
     val scc = new StreamingContext(conf, Seconds(1))
 
-    scc.scheduler.listenerBus.listeners.collect { case x: BatchInfoCollector => x}.size should be (1)
     scc.scheduler.listenerBus.listeners.collect {
-      case x: ReceiverInfoCollector =>
-    }.size should be (1)
+      case x: BatchInfoCollector => x }.size should be (1)
+    scc.scheduler.listenerBus.listeners.collect {
+      case x: ReceiverInfoCollector => x }.size should be (1)
   }
 }