add timeout for test
add timeouts for all streams
make stream stream a pipable duplex stream