Description
In AbstractReactiveElasticsearchTemplate, the reactive saveAll operation (used by save(Publisher<T> entities, ...) methods) uses an internal subscriber that lacks an error handler.
Steps to Reproduce
When a Flux emitting entities causes an error during processing (e.g., a transformation error or upstream failure), the error is swallowed by the inner subscriber. This causes the resulting Flux to hang indefinitely or terminate without the error signal reaching the caller.
Expected Behavior
Errors occurring during the reactive save operation should be propagated to the subscriber of the returned Flux.
Actual Behavior
Errors are swallowed in the internal .subscribe() call.