Skip to content

Commit

Permalink
Update README.md with assorted typo fixes (#22)
Browse files Browse the repository at this point in the history
  • Loading branch information
Ben Sandee authored and akarnokd committed May 21, 2018
1 parent 46026d4 commit 3a21b92
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand All @@ -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)
Expand Down Expand Up @@ -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
Expand All @@ -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) {
Expand Down Expand Up @@ -1113,15 +1113,15 @@ 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) {
return Flowable.fromArray(files);
}
}
return Flowable.empty();
}, ExpandStrategy.BREATH_FIRST))
}, ExpandStrategy.BREADTH_FIRST))
.subscribe(System.out::println);
// prints something like
Expand Down Expand Up @@ -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.

Expand Down

0 comments on commit 3a21b92

Please sign in to comment.