beamlime.applications.handlers.MergeMessageCountInterval#

beamlime.applications.handlers.MergeMessageCountInterval = beamlime.applications.handlers.MergeMessageCountInterval#

Every MergeMessageCountInterval-th message the data assembler receives the data reduction is run