Implement ofType to leverage Stream#flatMap instead of Stream#collect, so that filtering & mapping are lazily executed.