Foggy day

val intSrc = Observable.just(1, 2, 3) intSrc.subscribe(::println) val strSrc = intSrc.map { value -> value * 10 } strSrc.subscribe(::println) val src = Observable.just("A", "B", "C", "D") src.flatMap { s -> Observable.just(s + 2, s + 3) } src.subscribe(::println) val flatMap = Observable.range(2, 3).flatMap { x -> Observable.range(1, 9).map { y -> String.format("%d*%d=%d", x, y, x * y) } } flatM..

val items: PublishSubject = PublishSubject.create() items.onNext(1) items.onNext(2) items.onNext(3) items.filter { i -> i % 2 == 0 }.subscribe(::println) items.onNext(4) items.onNext(5) items.onNext(6) items.onNext(7) items.onNext(8)