3.3 Fixed retryWhen example

Author: Froussios

Part 3 - Taming the sequence/3. Advanced error handling.md

@@ -136,7 +136,8 @@ public final Observable<T> retryWhen(Func1<? super Observable<? extends java.lan
 
 The argument to `retryWhen` is a function that takes an observable and returns another. The input observable emits all the errors that `retryWhen` encounters. The resulting observable signals when to retry: 
 * if it emits a value, `retryWhen` will retry,
-* if it terminates, `retryWhen` will emit the error and not retry.
+* if it terminates with error, `retryWhen` will emit the error and not retry.
+* if it terminates successfully, `retryWhen` will terminate successfully
 Note that the type of the signaling obserable of the actual values emitted don't matter. The values are discarded and the observable is only used for timing.
 
 In the next example, we will construct a retrying policy where we wait 100ms before retrying.
@@ -147,22 +148,28 @@ Observable<Integer> source = Observable.create(o -> {
 	o.onNext(2);
 	o.onError(new Exception("Failed"));
 });
-	
-source.retryWhen((o) -> o.take(2).delay(100, TimeUnit.MILLISECONDS))
+
+source.retryWhen((o) -> o
+		.take(2)
+		.delay(100, TimeUnit.MILLISECONDS)
+		.concatWith(Observable.error(new Exception("Done"))))
 	.timeInterval()
-	.subscribe(System.out::println);
+	.subscribe(
+		System.out::println,
+		System.out::println);
 ```
 Output
 ```
-TimeInterval [intervalInMilliseconds=17, value=1]
+TimeInterval [intervalInMilliseconds=21, value=1]
 TimeInterval [intervalInMilliseconds=0, value=2]
-TimeInterval [intervalInMilliseconds=102, value=1]
+TimeInterval [intervalInMilliseconds=104, value=1]
 TimeInterval [intervalInMilliseconds=0, value=2]
-TimeInterval [intervalInMilliseconds=102, value=1]
+TimeInterval [intervalInMilliseconds=103, value=1]
 TimeInterval [intervalInMilliseconds=0, value=2]
+java.lang.Exception: Done
 ```
 
-Our source observable emits 2 values and immediately fails. When that happens, the observable of failures inside `retryWhen` emits the error. We delay that emission by 100ms and send it back to signal to retry. `take(2)` guarantees that our signaling observabe will terminate after we receive two errors. That means that `retryWhen` won't retry after 2 failures.
+Our source observable emits 2 values and immediately fails. When that happens, the observable of failures inside `retryWhen` emits the error. We delay that emission by 100ms and send it back to signal a retry. `take(2)` guarantees that our signaling observabe will terminate after we receive two errors. That means that `retryWhen` won't retry after 2 failures. We concatenate an error to make `retryWhen` also fail.
 
 ## using