fix(stream): correct cached input accounting