Refactoring: org.tchw.generic.stream