We now use Flux.flatMapSequential(…) instead of concatMap as concatMap reduces the request size to 1. The change in backpressure/request size reduces parallelism and impacts the batch size by fetching 2 documents instead of considering the actual backpressure.
flatMapSequential doesn't tamper the requested amount while retaining the sequence order.
Closes: #4543
Original Pull Request: #4550
This commit makes sure to fail early if an annotated string based annotation does not contain a syntactically valid pipeline.
Original pull request: #4547Closes#4546
This commit ensures to pass on a potentially set FullDocumentBeforeChange option to the change stream iterable/publisher.
It also corrects false optional behavior within the change stream task which did some defaulting though the actual value is an optional one that must not be present.
Original pull request: #4541Closes#4495
Contextual information required for converting values are now passed on correctly when projecting id properties.
Closes: #4524
Original pull request: #4525
This commit enables document reference lookup to use `DocumentReferenceSource` to properly instantiate an entity containig a @DocumentReference `#self` property.
Closes#4484
Original Pull Request: #4486
We now no longer attempt to complete the Observation if the context is not a MongoDB one. For commands that target the admin database and run within a parent observation, we still might have an Observation but that one points to the parent invocation and not the MongoDB one as we do not record commands for the admin database.
Closes#4481
This commit introduces a new AggregationVariable type that is intended to better identify variables within a pipeline to avoid mapping failures caused by invalid field names.
Closes#4070
Original pull request: #4242
Mark Paluch
Christoph Strobl
Christoph Strobl
Mark Paluch
John Blum
Julia