pitfall_10_fix.java

interface Service {	
	Flux<String> observe();
	Mono<Void> save(String s);
}
class Foo {
	private final Service service;
	
	void longRunningProblem() {
		service.observe()
			.flatMap(service::save, 10)
			.doOnTerminate(this::longRunningProblem) // start over on terminate
			.subscribeOn(Schedulers.elastic())
      			.retry() // retry indefinitely
			.subscribe();
	}
}