Skip to content

Commit 6d4f9b3

Browse files
committed
3.7 Fixed example
1 parent eecb297 commit 6d4f9b3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,8 @@ Observable<Integer> source = Observable.create(o -> {
280280
o.onCompleted();
281281
});
282282

283-
source.subscribe(
283+
source.doOnUnsubscribe(() -> System.out.println("Unsubscribed"))
284+
.subscribe(
284285
System.out::println,
285286
System.out::println,
286287
() -> System.out.println("Completed"));

0 commit comments

Comments
 (0)