[UnitTest] Check for specific amount of events to arrive

[wolframhaussig]

This issue is based on this discussion.

I want to create a test that checks for a specific number of events being published. The usecase here is that it should only publish events until a given limit of currently executing jobs is reached. This limit is used to prevent one instance of the service to block all jobs while another instance is idle.

scenario.stimulate(() -> collector.poll())
            .andWaitAtMost(Duration.ofSeconds(5))
            .andWaitForEventOfType(NewJobEvent.class)
           .count(3)
            .toArrive();