Support for reactive batch ops

[OlegDokuka]

https://jira.spring.io/browse/DATACASS-574

[OlegDokuka]

@mp911de ready to review.

Do we really need support for inserting Publisher? From my perspective, we will be able to execute elements draining only on the .execute method invocation. In turn, it will not give any benefits since we will have to collect data before writing, so in any case, it will be kind of "waiting point" + there is danger point that one sent infinitive stream, etc

[mp911de]

Thanks for raising this item. Accepting Publisher is an optimization which brings a challenge of batching and awaiting. In MongoDB, we switched to accept Mono<List<T>> to allow deferred inserts. Using the API would require to collect items upfront (.buffer() or .collectList()) and pass in the collected objects for a batch.

For the start, we're good without accepting Publisher.

[OlegDokuka]

I will add support for Publisher. Let me check Mongo api first in order to be aligned.

[OlegDokuka]

@mp911de done

[mp911de]

Thanks a lot. We're heading right now towards 2.1 RC1 so this pull request is a candidate for the second release candidate, 2.1 RC2.

[OlegDokuka]

@mp911de Great! Do I need to add/change something there or it is good to good but will be merged later?

[mp911de]

I haven't reviewed the pull request yet as we're currently busy with preparing 2.1 RC1.

[mp911de]

Thanks for your contribution. I had to convert spaces to tabs (please apply our formatting settings next time) and applied a round of polishing. You might be interested in 8055890.

That's merged and polished now.

[OlegDokuka]

hey @mp911de. Thank you for polishing. Should I add something else there

[mp911de]

Nothing left to do here.