Correctly piping interim streams through filters. Added helper method to create interim streams