user3762200 user3762200 - 3 months ago 89
Java Question

How to use RxJava combineLatest operator with more than 9 observables

I'm using RxJava and I want to combine 12 different observables using the operator

combineLatest
.

I saw a function prototype that takes a list of observables and an implementation of
FuncN
but I'm not sure how to do this, I'm having trouble implementing the
call
method.

Can someone show me an example?

Answer

There is a combineLatest that takes a List of observables. Here's an example on how to use it:

List<Observable<?>> list = Arrays.asList(Observable.just(1), Observable.just("2"));
Observable.combineLatest(list, new FuncN<String>() {
    @Override
    public String call(Object... args) {
        String concat = "";
        for (Object value : args) {
            if (value instanceof Integer) {
                concat += (Integer) value;
            } else if (value instanceof String) {
                concat += (String) value;
            }
        }
        return concat;
    }
});
Comments