[refactor] start working on forwardStream