fix(stream): remove redundant completion guard