MainListWithExample_Observable_withLatestFrom.java 文件源码

private Observable example4() {
    return Observable.interval(500, TimeUnit.MILLISECONDS).take(10)
            .withLatestFrom(
                    mObservables,
                    new FuncN<String>() {
                        @Override
                        public String call(Object... args) {
                            String s = "[";
                            for (Object object : args) {
                                s += object + ",";
                            }
                            s += "]";
                            return s;
                        }
                    });
}