Как запустить реактивный конвейер из события и запускать его при каждом срабатывании события ...
Значение внутри события не имеет значения ...
Пока чтоУ меня есть:
PublishSubject<Object> linkAll = PublishSubject.create();
linkAll.flatMap(x -> getObservableThatFetchesData())
.doOnNext(data -> actOnTheData(data)).subscribe();
И затем, когда событие происходит, я делаю:
linkAll.onNext("start");
Теперь это прекрасно работает ... но только один раз. Событие работает только один раз.
Я хочу, чтобы конвейер "запускался" каждый раз, когда событие запускается ...