I find the duplication of the complicated stream code to be an instance of avoiding premature abstraction; code requirements could change, they might need to be

I find the duplication of the complicated stream code to be an instance of avoiding premature abstraction; code requirements could change, they might need to be treated differently, and this makes it easier to customize later* * I grant that in this case (har har) it's fairly trivial.