class_docstr: A stream of RequestOutputs for a request that can be
  iterated over asynchronously.
class_docstr_tok: ["A","stream","of","RequestOutputs","for","a","request","that","can","be","iterated","over","asynchronously","."]
code: def __init__(self, request_id: str) -> None:
      self.request_id = request_id
      self._queue = asyncio.Queue()
      self._finished = False
  
imports: import asyncio
  import time
  from functools import partial
  from typing import Any, Dict, Iterable, List, Optional, Set, Tuple, Type, Union
  from bigdl.llm.vllm.config import ModelConfig
  from bigdl.llm.vllm.engine.arg_utils import AsyncEngineArgs
  from bigdl.llm.vllm.engine.llm_engine import LLMEngine
  from bigdl.llm.vllm.logger import init_logger
  from bigdl.llm.vllm.outputs import RequestOutput
  from bigdl.llm.vllm.sampling_params import SamplingParams
  from bigdl.llm.utils.common import invalidInputError
label_desc: Use image node_id 1 to create a new AsyncStream object  with example: obj = AsyncStream(request_id)