From 3306774be37c549a396063c39f29a6dc3a126e30 Mon Sep 17 00:00:00 2001
From: Feynman Liang <feynmanliang@users.noreply.github.com>
Date: Tue, 16 May 2017 17:09:40 -0700
Subject: [PATCH 1/2] Make examples in README compile

---
 README.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/README.md b/README.md
index 730fcecb..08595016 100644
--- a/README.md
+++ b/README.md
@@ -334,7 +334,7 @@ object StartTransactionExample extends App {
 import akka.actor._
 import eventstore.LiveProcessingStarted
 import eventstore.tcp.ConnectionActor
-import eventstore.{ IndexedEvent, SubscriptionActor }
+import eventstore.{ IndexedEvent, Settings, SubscriptionActor }
 import scala.concurrent.duration._
 
 object CountAll extends App {
@@ -428,7 +428,7 @@ object MessagesPerSecond extends App {
   val connection = EventStoreExtension(system).connection
   val publisher = connection.allStreamsPublisher()
 
-  Source(publisher)
+  Source.fromPublisher(publisher)
     .groupedWithin(Int.MaxValue, 1.second)
     .runForeach { xs => println(f"${xs.size.toDouble / 1000}%2.1fk m/s") }
 }

From 35f14978c84497b7eb78e6ddbab0956faff3536f Mon Sep 17 00:00:00 2001
From: Feynman Liang <feynmanliang@users.noreply.github.com>
Date: Tue, 16 May 2017 17:10:28 -0700
Subject: [PATCH 2/2] Update README.md

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 08595016..fe785829 100644
--- a/README.md
+++ b/README.md
@@ -449,7 +449,7 @@ object ListAllStreamsExample extends App {
   implicit val materializer = ActorMaterializer()
   val connection = EventStoreExtension(system).connection
   val publisher = connection.streamPublisher(EventStream.System.`$streams`, infinite = false, resolveLinkTos = true)
-  Source(publisher)
+  Source.fromPublisher(publisher)
     .runForeach { x => println(x.streamId.streamId) }
     .onComplete{ _ => system.terminate()}
 }