code: def test_async_custom_handler_stream():
      try:
          # [PROD Test] - Do not DELETE
          # checks if the model response available in the async + stream callbacks is equal to the received response
          customHandler2 = MyCustomHandler()
          litellm.callbacks = [customHandler2]
          litellm.set_verbose = False
          messages = [
              {
                  "role": "system",
                  "content": "You are a helpful assistant.",
              },
              {
                  "role": "user",
                  "content": "write 1 sentence about litellm being amazing",
              },
          ]
          complete_streaming_response = ""
  
          async def test_1():
              nonlocal complete_streaming_response
              response = await litellm.acompletion(
                  model="azure/chatgpt-v-2",
                  messages=messages,
                  stream=True,
              )
              async for chunk in response:
                  complete_streaming_response += (
                      chunk["choices"][0]["delta"]["content"] or ""
                  )
                  print(complete_streaming_response)
  
          asyncio.run(test_1())
  
          response_in_success_handler = (
              customHandler2.stream_collected_response
          )
          response_in_success_handler = response_in_success_handler[
              "choices"
          ][0]["message"]["content"]
          print("\n\n")
          print(
              "response_in_success_handler: ",
              response_in_success_handler,
          )
          print(
              "complete_streaming_response: ",
              complete_streaming_response,
          )
          assert (
              response_in_success_handler == complete_streaming_response
          )
      except Exception as e:
          pytest.fail(f"Error occurred: {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 3 for calling a global function with example usage: test_async_custom_handler_stream() without return types