Linked to examples

Author: Froussios

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

@@ -173,6 +173,8 @@ public class RunningAverage implements Observable.Transformer<Integer, Double> {
 
 We just added the parameter as a field in the operator, added constructors for the uses that we cover and used the parameter in our Rx operations. Now we can do `source.compose(new RunningAverage(5))`, where, ideally, we would be calling `source.runningAverage(5)`. Java only lets us go this far. Rx is a functional paradigm, but Java is still primarily an object oriented language and quite conservative at that.
 
+You can a complete example of for this example operator [here](/tests/java/itrx/chapter3/custom/ComposeExample.java).
+
 ### lift
 
 Internally, every Rx operator does 3 things
@@ -239,7 +241,7 @@ Observable.range(0, 5)
 	.lift(new MyMap<Integer, String>(i -> i + "!"))
 	.subscribe(System.out::println);
 ```
-Output
+[Output](/tests/java/itrx/chapter3/custom/LiftExample.java)
 ```
 0!
 1!
@@ -289,7 +291,7 @@ source.doOnUnsubscribe(() -> System.out.println("Unsubscribed"))
 		System.out::println,
 		() -> System.out.println("Completed"));
 ```
-Output
+[Output](/tests/java/itrx/chapter3/custom/SerializeExample.java)
 ```
 1
 2
@@ -326,7 +328,7 @@ source.doOnUnsubscribe(() -> System.out.println("Unsubscribed"))
 		}
 });
 ```
-Output
+[Output](/tests/java/itrx/chapter3/custom/SerializeExample.java)
 ```
 1
 2
@@ -369,7 +371,7 @@ source.doOnUnsubscribe(() -> System.out.println("Unsubscribed"))
 		}
 });
 ```
-Output
+[Output](/tests/java/itrx/chapter3/custom/SerializeExample.java)
 ```
 1
 2