merge-batch-stream: Make batchsize configurable in Flux

[TobiasNx]

Resolves #782

Reuse adjustment from ObjectSleeper.java 18b6ae0

[TobiasNx]

@dr0i could you do an functional review? I also added a test workflow here: TobiasNx/notWorkingFlux@f841b1f

[blackwinter]

Functional review is done on the issue. You have to assign @dr0i there (and move the issue to the review status).

[blackwinter]

Please add an integration test so we can be sure not to introduce a regression in the future.

[TobiasNx]

Please add an integration test so we can be sure not to introduce a regression in the future.

There already exists an tests for batchSize. But I do not know how to build a test that checks for a specific datatype:

metafacture-core/metafacture-plumbing/src/test/java/org/metafacture/plumbing/StreamBatchMergerTest.java

Lines 51 to 53 in 9a543c5

	@Test
	public void testShouldMergeNConsecutiveRecords() {
	batchMerger.setBatchSize(2);

[blackwinter]

But I do not know how to build a test that checks for a specific datatype

Exactly, that's why I said integration test. There you specify a Flux workflow which uses the new setter - which is the actual goal of this pull request.

[TobiasNx]

But I do not know how to build a test that checks for a specific datatype

Exactly, that's why I said integration test. There you specify a Flux workflow which uses the new setter - which is the actual goal of this pull request.

Should I add this integration test in context of metafix (metafix/src/test/resources/org/metafacture/metafix/integration)?

[blackwinter]

Yes, that's the only place we currently have them.