Skip to content

Typo fix in Part 3 Chapter 5#56

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Froussios merged 1 commit into from
Jul 13, 2020
Merged

Typo fix in Part 3 Chapter 5 #56

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions Part 3 - Taming the sequence/5. Time-shifted sequences.md
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -81,7 +81,7 @@ We see a lot of empty lists here. This is because the buffer is emitted both whe

#### buffer with signal

Instead of fixed points in time, you can also signal `buffer` with an observable to flush. Every time the signal emits onNext, the values in the buffer will be emitted will be emitted. Buffering with a signal can be very useful if you want to buffer values until the moment that you are ready for them.
Instead of fixed points in time, you can also signal `buffer` with an observable to flush. Every time the signal emits onNext, the values in the buffer will be emitted. Buffering with a signal can be very useful if you want to buffer values until the moment that you are ready for them.

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

Expand DownExpand Up@@ -155,7 +155,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(10)

#### buffer by signal

The last and most powerful variant or `buffer` allows you to define the start and the end of buffers using signaling observables.
The last and most powerful variant of `buffer` allows you to define the start and the end of buffers using signaling observables.
```java
public final <TOpening,TClosing> Observable<java.util.List<T>> buffer(
Observable<? extends TOpening> bufferOpenings,
Expand Down