From 3a21b92cf975cec290b2228e3c68443909bb8f10 Mon Sep 17 00:00:00 2001 From: Ben Sandee Date: Mon, 21 May 2018 15:48:39 -0500 Subject: [PATCH] Update README.md with assorted typo fixes (#22) --- README.md | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/README.md b/README.md index e2c8a81b..a658ee12 100644 --- a/README.md +++ b/README.md @@ -1025,7 +1025,7 @@ Flowable.just(100, 300, 500) ### FlowableTransformers.flatMapSync() -A bounded-concurrency `flatMap` implementation optimized for mostly non-trivial, largely synchronous sources in mind and using different tracking method and configurable merging strategy: depth-first consumes each inner source as much as possible before switching to the next; breath-first consumes one element from each source in a round-robin fashion. Overloads allow specifying the concurrency level (32 default), inner-prefetch (`Flowable.bufferSize()` default) and the merge strategy (depth-first default). +A bounded-concurrency `flatMap` implementation optimized for mostly non-trivial, largely synchronous sources in mind and using different tracking method and configurable merging strategy: depth-first consumes each inner source as much as possible before switching to the next; breadth-first consumes one element from each source in a round-robin fashion. Overloads allow specifying the concurrency level (32 default), inner-prefetch (`Flowable.bufferSize()` default) and the merge strategy (depth-first default). ```java Flowable.range(1, 1000) @@ -1038,7 +1038,7 @@ Flowable.range(1, 1000) ### FlowableTransformers.flatMapAsync() -A bounded-concurrency `flatMap` implementation taking a scheduler which is used for collecting and emitting items from the active sources and freeing up the inner sources to keep producing. It also uses a different tracking method and configurable merging strategy: depth-first consumes each inner source as much as possible before switching to the next; breath-first consumes one element from each source in a round-robin fashion. Overloads allow specifying the concurrency level (32 default), inner-prefetch (`Flowable.bufferSize()` default) and the merge strategy (depth-first default). +A bounded-concurrency `flatMap` implementation taking a scheduler which is used for collecting and emitting items from the active sources and freeing up the inner sources to keep producing. It also uses a different tracking method and configurable merging strategy: depth-first consumes each inner source as much as possible before switching to the next; breadth-first consumes one element from each source in a round-robin fashion. Overloads allow specifying the concurrency level (32 default), inner-prefetch (`Flowable.bufferSize()` default) and the merge strategy (depth-first default). ```java Flowable.range(1, 1000) @@ -1069,7 +1069,7 @@ Flowable.empty() ### FlowableTransformers.expand() Streams values from the main source, maps each of them onto another Publisher and recursively streams those Publisher values until all Publishers terminate. -Two recursing mode is available: breath-first will stream the main source (level 1), then the Publishers generated by its items (level 2), then the Publishers generated by the level 2 +Two recursing mode is available: breadth-first will stream the main source (level 1), then the Publishers generated by its items (level 2), then the Publishers generated by the level 2 and so on; depth-first will take an item from the main source, maps it to a Publisher then takes an item from this Publisher and maps it further. ```java @@ -1083,7 +1083,7 @@ Depth-first example: ```java Flowable.just(new File(".")) -.compose(FlowableTransofmers.expand(file -> { +.compose(FlowableTransformers.expand(file -> { if (file.isDirectory()) { File[] files = file.listFiles(); if (files != null) { @@ -1113,7 +1113,7 @@ Breadth-first example: ```java Flowable.just(new File(".")) -.compose(FlowableTransofmers.expand(file -> { +.compose(FlowableTransformers.expand(file -> { if (file.isDirectory()) { File[] files = file.listFiles(); if (files != null) { @@ -1121,7 +1121,7 @@ Flowable.just(new File(".")) } } return Flowable.empty(); -}, ExpandStrategy.BREATH_FIRST)) +}, ExpandStrategy.BREADTH_FIRST)) .subscribe(System.out::println); // prints something like @@ -1713,7 +1713,7 @@ Flowable.range(1, 5) ### ParallelTransformers.orderedMerge() -Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from +Merges the source `ParallelFlowable` rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order or via a `Comparator`). The operator supports delaying error and setting the internal prefetch amount.