added stream cleave functionality
reduce for stream
separated stream tests