code: def test_buffered_proto_create_connection(self):
      NOISE = b"12345678+" * 1024
  
      async def client(addr):
          data = b""
  
          def on_buf(buf):
              nonlocal data
              data += buf
              if data == NOISE:
                  tr.write(b"1")
  
          conn_lost_fut = self.loop.create_future()
  
          tr, pr = await self.loop.create_connection(
              lambda: ReceiveStuffProto(on_buf, conn_lost_fut), *addr
          )
  
          await conn_lost_fut
  
      async def on_server_client(reader, writer):
          writer.write(NOISE)
          await reader.readexactly(1)
          writer.close()
          await writer.wait_closed()
  
      srv = self.loop.run_until_complete(
          asyncio.start_server(on_server_client, "127.0.0.1", 0)
      )
  
      addr = srv.sockets[0].getsockname()
      self.loop.run_until_complete(asyncio.wait_for(client(addr), 5))
  
      srv.close()
      self.loop.run_until_complete(srv.wait_closed())
  
imports: import asyncio
  import unittest
  from test.test_asyncio import functional
label_desc: Use image node_id 2 for calling the BaseTestBufferedProtocol obj's underlying member method code with example usage: obj.test_buffered_proto_create_connection() without return types