diff --git a/doc/streaming.md b/doc/streaming.md
index 09c0a0f3..d23bd90f 100644
--- a/doc/streaming.md
+++ b/doc/streaming.md
@@ -119,6 +119,7 @@ import com.redislabs.provider.redis.streaming._
 val ssc = new StreamingContext(sc, Seconds(1))
 val redisStream = ssc.createRedisStream(Array("foo", "bar"), storageLevel = StorageLevel.MEMORY_AND_DISK_2)
 redisStream.print()
+ssc.start()
 ssc.awaitTermination()
 ```
 
@@ -132,5 +133,6 @@ import com.redislabs.provider.redis.streaming._
 val ssc = new StreamingContext(sc, Seconds(1))
 val redisStream = ssc.createRedisStreamWithoutListname(Array("foo", "bar"), storageLevel = StorageLevel.MEMORY_AND_DISK_2)
 redisStream.print()
+ssc.start()
 ssc.awaitTermination()
 ```