fstn
10/21/2017, 7:27 PMrx.Observable.merge(
events.map{
eventbus.rxSend(....).toObservalbe()
}
}.subscribe(next,error)
edwardwongtl
10/21/2017, 7:41 PMflatMap
instead of map
fstn
10/21/2017, 7:42 PMObservable.from(validEvents).flatMap { notifyNextNode(node, it, messageBody, send) }
edwardwongtl
10/21/2017, 7:57 PMfstn
10/21/2017, 7:58 PMedwardwongtl
10/21/2017, 7:59 PMList<Observable>
into Observable
fstn
10/21/2017, 7:59 PMedwardwongtl
10/21/2017, 7:59 PMfstn
10/21/2017, 8:00 PMvalidEvents.toObservable().flatMap { notifyNextNode(node, it, messageBody, send) }
edwardwongtl
10/21/2017, 8:03 PMevents.merge().subscribe { notifyNextNode(...) }
fstn
10/21/2017, 8:05 PMedwardwongtl
10/21/2017, 8:12 PMfstn
10/22/2017, 4:38 AMedwardwongtl
10/22/2017, 8:03 AMfstn
10/22/2017, 8:05 AM