code: def test_streaming_response_create(self, client: OpenAI) -> None:
      with client.beta.threads.messages.with_streaming_response.create(
          "string",
          content="x",
          role="user",
      ) as response:
          assert not response.is_closed
          assert (
              response.http_request.headers.get("X-Stainless-Lang")
              == "python"
          )
  
          message = response.parse()
          assert_matches_type(ThreadMessage, message, path=["response"])
  
      assert cast(Any, response.is_closed) is True
  
imports: from __future__ import annotations
  import os
  from typing import Any, cast
  import pytest
  from openai import OpenAI, AsyncOpenAI
  from tests.utils import assert_matches_type
  from openai._client import OpenAI, AsyncOpenAI
  from openai.pagination import SyncCursorPage, AsyncCursorPage
  from openai.types.beta.threads import ThreadMessage
label_desc: Use image node_id 4 for calling the TestMessages obj's underlying member method code with example usage: obj.test_streaming_response_create(client) without return types