Add stream integration tests