Skip to content

Commit 0c1820f

Browse files
committed
Merge pull request #13 from Froussios/Unpublished-content
More typos
2 parents fb73fa6 + e6a729c commit 0c1820f

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

Part 2 - Sequence Basics/4. Aggregation.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -543,7 +543,7 @@ Nested observables may be confusing at first, but they are a powerful construct
543543

544544
### nest
545545

546-
When dealing with nested observables, the `nest` operator becomes useful. It allows you to turn a non-nested observable into a nested observable. `nest` takes a source observable and returns an observable that will be the source observable and then terminate.
546+
When dealing with nested observables, the `nest` operator becomes useful. It allows you to turn a non-nested observable into a nested one. `nest` takes a source observable and returns an observable that will emit the source observable and then terminate.
547547

548548
![](https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/nest.png)
549549

@@ -559,7 +559,7 @@ Observable.range(0, 3)
559559
2
560560
```
561561

562-
Nesting observables to consume them doesn't make much sense. Towards the end of the pipeline, you'd rather flatten and simply your observables, rather than nest them. Nesting is useful when you need to make a non-nested observable be of the same type as a nested observable that you have from elsewhere. Once they are of the same type, you can combine them, as we will see in the chapter about [combining sequences](/Part 3 - Taming the sequence/4. Combining sequences.md).
562+
Nesting observables to consume them doesn't make much sense. Towards the end of the pipeline, you'd rather flatten and simplify your observables, rather than nest them. Nesting is useful when you need to make a non-nested observable be of the same type as a nested observable that you have from elsewhere. Once they are of the same type, you can combine them, as we will see in the chapter about [combining sequences](/Part 3 - Taming the sequence/4. Combining sequences.md).
563563

564564

565565

Part 3 - Taming the sequence/7. Custom operators.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ source.doOnUnsubscribe(() -> System.out.println("Unsubscribed"))
378378
Completed
379379
```
380380

381-
We here that, despite the fact that we did not unsubscribe, the illegal notifications were filtered out.
381+
We see that, despite the fact that we did not unsubscribe, the illegal notifications were filtered out.
382382

383383

384384

Part 4 - Concurrency/4. Backpressure.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ The `request(1)` in `onStart` establishes backpressure and informs the observabl
147147

148148
### doOnRequested
149149

150-
Back we where discussing the `doOn_` operators for [side effects](/Part%203%20-%20Taming%20the%20sequence/1.%20Side%20effects.md#do), we left out `doOnRequested`.
150+
Back when we were discussing the `doOn_` operators for [side effects](/Part%203%20-%20Taming%20the%20sequence/1.%20Side%20effects.md#do), we left out `doOnRequested`.
151151
```java
152152
public final Observable<T> doOnRequest(Action1<java.lang.Long> onRequest)
153153
```
@@ -348,7 +348,7 @@ Observable.interval(1, TimeUnit.MILLISECONDS)
348348
...
349349
```
350350

351-
What we see here is that the first 128 items where consumed normally, but then we jumped forward. The items inbetween were dropped by `onBackPressureDrop`. Even though we did not request it, the first 128 items where still buffered, since `observeOn` uses a small buffer between switching threads.
351+
What we see here is that the first 128 items where consumed normally, but then we jumped forward. The items inbetween were dropped by `onBackPressureDrop`. Even though we did not request it, the first 128 items were still buffered, since `observeOn` uses a small buffer between switching threads.
352352

353353

354354
| Previous | Next |

0 commit comments

Comments
 (0)