Как отправить события из Observable между двумя подписчиками?

Question

Как реализовать поведение типа «балансировка нагрузки» на наблюдаемом. Допустим, у нас есть List<Subscriber<String>>> subscribers, и каждая сохраняет строки в файл в своем собственном потоке, а события из Observable<String> распределяются поровну между подписчиками:

List<Subscriber<String>>> subscribers = ...
Scheduler s = Schedulers.from(new ForkJoinPool(subscribers.size()))
Observable<String> observable = ....
observable.subscribe(s-> subscribers.get(i% subscribers.size()).onNext(s)))

???