msg.reply("pong"+msg.body());
}
});
Observable<RxMessage<String>> obs1 = rxEventBus.send("foo", "A");
Observable<RxMessage<String>> obs2 = rxEventBus.send("foo", "B");
Observable<RxMessage<String>> obs3 = rxEventBus.send("foo", "C");
Observable<RxMessage<String>> merged = Observable.merge(obs1, obs2, obs3);
Observable<String> result = merged.reduce("", new Func2<String, RxMessage<String>, String>() {
@Override
public String call(String accum, RxMessage<String> reply) {