use another stream function in migration