Foggy day

val source = Observable.create { emitter: ObservableEmitter? -> emitter?.onNext("Hello") emitter?.onNext("android") emitter?.onComplete() }.subscribe(::println) // source.subscribe(::println) val source = Observable.just("Hello", "android") source.subscribe(::println) val stringList = listOf("A", "B", "C") val source = Observable.fromArray(stringList) source.subscribe(::println) val stringArrayL..

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)