Added a varient of streams4 which listens for the end event to indicate read stream is consumed.