Skip to content

Conversation

@Suresh-Sreerama
Copy link

No description provided.

* process
*/
BatchCollector(int batchSize, boolean enforceStrictBatching, Consumer<List<T>> batchProcessor) {
this.batchSize = batchSize;
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We seem to have lost the non-null check:
batchProcessor = requireNonNull(batchProcessor);

@rovats
Copy link
Owner

rovats commented Dec 29, 2019

Thanks for contributing.

Could you please add some tests for the strict batching feature when convenient?

@Suresh-Sreerama
Copy link
Author

Sorry about the jUnit tests. I will be committing them shortly. I had the test written but forgot to commit. I am a bit of newbie with Git.

The null check is still on in the new constructor. The previous constructor calls the new on with strict batching set to: false.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants