ObservableExample.java

List<Integer> integerList = IntStream.range(1, 11).boxed().collect(Collectors.toList());

Observable<Integer> integerObservable = Observable.fromIterable(integerList)
    .map(integer -> integer * 2);

Disposable subscribe1 = integerObservable
    .map(integer -> integer * 10)
    .subscribe(integer -> System.out.println("From first subscriber: "+integer));

Disposable subscribe2 = integerObservable
    .map(integer -> integer * 100)
    .subscribe(integer -> System.out.println("From second subscriber: "+integer));