code: def test_start_unix_server_1(self):
      HELLO_MSG = b"1" * 1024 * 5 + b"\n"
      started = threading.Event()
  
      def client(sock, addr):
          sock.settimeout(2)
          started.wait(5)
          sock.connect(addr)
          sock.send(HELLO_MSG)
          sock.recv_all(1)
          sock.close()
  
      async def serve(reader, writer):
          await reader.readline()
          main_task.cancel()
          writer.write(b"1")
          writer.close()
          await writer.wait_closed()
  
      async def main(srv):
          async with srv:
              self.assertFalse(srv.is_serving())
              await srv.start_serving()
              self.assertTrue(srv.is_serving())
              started.set()
              await srv.serve_forever()
  
      with test_utils.unix_socket_path() as addr:
          srv = self.loop.run_until_complete(
              asyncio.start_unix_server(
                  serve, addr, start_serving=False
              )
          )
  
          main_task = self.loop.create_task(main(srv))
  
          with self.assertRaises(asyncio.CancelledError):
              with self.unix_client(lambda sock: client(sock, addr)):
                  self.loop.run_until_complete(main_task)
  
          self.assertEqual(srv.sockets, ())
  
          self.assertIsNone(srv._sockets)
          self.assertIsNone(srv._waiters)
          self.assertFalse(srv.is_serving())
  
          with self.assertRaisesRegex(RuntimeError, r"is closed"):
              self.loop.run_until_complete(srv.serve_forever())
  
imports: import asyncio
  import os
  import socket
  import time
  import threading
  import unittest
  from test.support import socket_helper
  from test.test_asyncio import utils
  from test.test_asyncio import functional
label_desc: Use image node_id 2 for calling the SelectorStartServerTests obj's underlying member method code with example usage: obj.test_start_unix_server_1() without return types