Параллельный Hystrix. Повышаем производительность распределенных приложений

[veHab13]

Observable<String> observable =  Observable.from(source)
                        .map(elem -> executeCommandDelayed(elem.toString()))
                        .window(7)
                        .concatMap(window -> window.flatMap(x -> x));

можно заменить на

Observable<String> observable =  Observable.from(source)
                .flatMap(elem -> executeCommandDelayed(elem.toString()), 7);

или если нужно сохранить порядок возвращаемых значений, но при этом отправлять запросы пачками, то concatMapEager

Observable<String> observable =  Observable.from(source)
                .concatMapEager(elem -> executeCommandDelayed(elem.toString()), 128, 7);