code: def test_get_response_non_openai_streaming():
      import asyncio
  
      litellm.set_verbose = True
      litellm.num_retries = 0
  
      async def test_async_call():
          user_message = "Hello, how are you?"
          messages = [{"content": user_message, "role": "user"}]
          try:
              response = await acompletion(
                  model="anyscale/mistralai/Mistral-7B-Instruct-v0.1",
                  messages=messages,
                  stream=True,
                  timeout=5,
              )
              print(type(response))
  
              import inspect
  
              is_async_generator = inspect.isasyncgen(response)
              print(is_async_generator)
  
              output = ""
              i = 0
              async for chunk in response:
                  token = chunk["choices"][0]["delta"].get(
                      "content", None
                  )
                  if token == None:
                      continue
                  print(token)
                  output += token
              print(f"output: {output}")
              assert output is not None, "output cannot be None."
              assert isinstance(
                  output, str
              ), "output needs to be of type str"
              assert (
                  len(output) > 0
              ), "Length of output needs to be greater than 0."
          except litellm.Timeout as e:
              pass
          except Exception as e:
              pytest.fail(f"An exception occurred: {e}")
          return response
  
      asyncio.run(test_async_call())
  
file_path: litellm/litellm/tests/test_async_fn.py
imports: import sys, os
  import pytest
  import traceback
  import asyncio, logging
  import litellm
  from litellm import completion, acompletion, acreate
label_desc: Use image node_id 8 for calling a global function with example usage: test_get_response_non_openai_streaming() and returns: response