I guess in your case, the collector would produce ...

# announcements

[purereborn]

I guess in your case, the collector would produce a Set<IntRange>, for each new IntRange it'd check if there is an overlapping one that needs to be expanded, then you'd stream over the resulting Set and process each of the IntRange?