reiseburo
/
beetle
mirror of https://github.com/reiseburo/beetle
1
0
Fork 0
Code Issues Releases Wiki Activity

Rephrase my prototype API

This commit is contained in:
R. Tyler Croy 2015-09-03 13:21:19 -07:00
parent 5ecbc06923
commit 07fa6dcfad
No known key found for this signature in database
GPG Key ID: 1426C7DC3F51E16F
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
README.adoc
View File

@ -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());
----