[JAVA-4010] Propagate the batch size in ChangeStreamPublisherImpl.withDocumentClass Created: 11/Feb/21  Updated: 28/Oct/23  Resolved: 21/Jun/21

Status: Closed
Project: Java Driver
Component/s: Reactive Streams
Affects Version/s: None
Fix Version/s: 4.3.0

Type: Bug Priority: Major - P3
Reporter: Valentin Kavalenka Assignee: Valentin Kavalenka
Resolution: Fixed Votes: 0
Labels: None
Remaining Estimate: Not Specified
Time Spent: Not Specified
Original Estimate: Not Specified

Issue Links:
Issue split
split from JAVA-3990 Implement change stream oplog parsing... Closed
Backwards Compatibility: Fully Compatible
Documentation Changes: Not Needed

 Description   

BatchCursorFlux respects the batch size of its BatchCursorPublisher if any is specified (see BatchCursorFlux.calculateBatchSize). Currently the method ChangeStreamPublisherImpl.withDocumentClass creates a new BatchCursorPublisher but does not propagate its batch size (if specified) to the created BatchCursorPublisher.

I discovered this while trying to run poc-change-streams.json (POC unified tests) with a reactive driver.



 Comments   
Comment by Githook User [ 21/Jun/21 ]

Author:

{'name': 'Valentin Kovalenko', 'email': 'valentin.kovalenko@mongodb.com', 'username': 'stIncMale'}

Message: Propagate the batch size in ChangeStreamPublisherImpl.withDocumentClass (#664)

Propagate the batch size in `ChangeStreamPublisherImpl.withDocumentClass`

JAVA-4010

Co-authored-by: Ross Lawley <ross.lawley@gmail.com>
Branch: master
https://github.com/mongodb/mongo-java-driver/commit/3196681720bb4e5ec43ed10cabf270831d34b1c1

Generated at Thu Feb 08 09:01:00 UTC 2024 using Jira 9.7.1#970001-sha1:2222b88b221c4928ef0de3161136cc90c8356a66.