Skip to content

Commit 1e7adea

Browse files
committed
Improved phrasing
1 parent 1a7e81a commit 1e7adea

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ Observable.range(0, 5)
258258
.subscribe(System.out::println);
259259
```
260260

261-
There are a few things to consider when doing manual pushes to subscribers
261+
When doing manual pushes to subscribers, like we do when implementing `Observable.Operator`, there are a few things to consider
262262
* A subscriber is free to unsubscribe. Don't push without checking first: `!subscriber.isUnsubscribed()`.
263263
* You are responsible for complying with the Rx contract: any number of `onNext` notifications, optionally followed by a single `onCompleted` or `onError`.
264264
* If you are going to use asynchronous operations and scheduling, use the [Schedulers](/Part%204%20-%20Concurrency/1.%20Scheduling%20and%20threading.md#Schedulers) of Rx. That will allow your operator to become [testable](/Part%204%20-%20Concurrency/2.%20Testing%20Rx.md#testscheduler).

0 commit comments

Comments
 (0)