code: def test_async_chat_openai_stream():
      try:
          tmp_function = TmpFunction()
          # litellm.set_verbose = True
          litellm.success_callback = [
              tmp_function.async_test_logging_fn
          ]
          complete_streaming_response = ""
  
          async def call_gpt():
              nonlocal complete_streaming_response
              response = await litellm.acompletion(
                  model="gpt-3.5-turbo",
                  messages=[
                      {"role": "user", "content": "Hi 👋 - i'm openai"}
                  ],
                  stream=True,
              )
              async for chunk in response:
                  complete_streaming_response += (
                      chunk["choices"][0]["delta"]["content"] or ""
                  )
                  print(complete_streaming_response)
  
          asyncio.run(call_gpt())
          complete_streaming_response = (
              complete_streaming_response.strip("'")
          )
          response1 = (
              tmp_function.complete_streaming_response_in_callback[
                  "choices"
              ][0]["message"]["content"]
          )
          response2 = complete_streaming_response
          # assert [ord(c) for c in response1] == [ord(c) for c in response2]
          assert response1 == response2
          assert tmp_function.async_success == True
      except Exception as e:
          print(e)
          pytest.fail(f"An error occurred - {str(e)}")
  
file_path: litellm/litellm/tests/test_custom_logger.py
imports: import sys, os, time, inspect, asyncio, traceback
  import pytest
  from litellm import completion, embedding
  import litellm
  from litellm.integrations.custom_logger import CustomLogger
label_desc: Use image node_id 1 for calling a global function with example usage: test_async_chat_openai_stream() without return types