From 07fa6dcfadebbf4478373fc12cb6f3d41c7d2500 Mon Sep 17 00:00:00 2001
From: "R. Tyler Croy" <tyler@monkeypox.org>
Date: Thu, 3 Sep 2015 13:21:19 -0700
Subject: [PATCH] Rephrase my prototype API

---
 README.adoc | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/README.adoc b/README.adoc
index 14a4fa9..c84b641 100644
--- a/README.adoc
+++ b/README.adoc
@@ -43,8 +43,9 @@ Subscribers, e.g.g
 [source, java]
 ----
 /* Using Java 8 Lambda syntax for conciseness' sake */
-BrokerDiscovery.zookeeper("localhost:2181")
+LocateBrokers.zookeeper("localhost:2181")
     .map(broker -> TopicSubscription("some-topic"))
-    .map(message -> doSomethingWithMessage(message); message)
+    /* assuming a custom consume() operator exists in Beetle */
+    .consume(message -> doSomethingWithMessage(message))
     .map(message -> message.commitOffset());
 ----