Looks to me that the batch is only created by the scheduler thread. So, the consumer of this will get either 1 or X batches after a fixed time period, rite?