Dynamically create intermediate Streams based on the same implementation type, removing the need to duplicate code.