Repository: bahir Updated Branches: refs/heads/master eab486427 -> 31b3e96d4
[BAHIR-52] Fix code paragraph formatting for Akka readme Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/31b3e96d Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/31b3e96d Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/31b3e96d Branch: refs/heads/master Commit: 31b3e96d4680c54ff05d4b09f944106d22b62760 Parents: eab4864 Author: Luciano Resende <[email protected]> Authored: Wed Aug 10 14:54:41 2016 -0700 Committer: Luciano Resende <[email protected]> Committed: Wed Aug 10 14:54:41 2016 -0700 ---------------------------------------------------------------------- streaming-akka/README.md | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/31b3e96d/streaming-akka/README.md ---------------------------------------------------------------------- diff --git a/streaming-akka/README.md b/streaming-akka/README.md index 16ede09..531340e 100644 --- a/streaming-akka/README.md +++ b/streaming-akka/README.md @@ -40,10 +40,9 @@ this actor can be configured to handle failures, etc. } } -// A new input stream can be created with this custom actor as -val ssc: StreamingContext = ... -val lines = AkkaUtils.createStream[String](ssc, Props[CustomActor](), "CustomReceiver") - + // A new input stream can be created with this custom actor as + val ssc: StreamingContext = ... + val lines = AkkaUtils.createStream[String](ssc, Props[CustomActor](), "CustomReceiver") ### Java API @@ -57,9 +56,8 @@ this actor can be configured to handle failures, etc. } } -// A new input stream can be created with this custom actor as -JavaStreamingContext jssc = ...; -JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Props.create(CustomActor.class), "CustomReceiver"); -``` + // A new input stream can be created with this custom actor as + JavaStreamingContext jssc = ...; + JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Props.create(CustomActor.class), "CustomReceiver"); See end-to-end examples at [Akka Examples](https://github.com/apache/bahir/tree/master/streaming-akka/examples)
