code: def _wrap_test(server_started_event, conf, tp):
      async def _test():
          async def check_data(chan: SocketChannel):
              np.testing.assert_array_equal(
                  test_data, await chan.recv()
              )
              await chan.send("success")
  
          nonlocal conf
          conf = conf.copy()
          conf["handle_channel"] = check_data
  
          # create server
          server = await tp.create(conf)
          await server.start()
          server_started_event.set()
          await server.join()
  
      asyncio.run(_test())
  
file_path: mars/mars/oscar/backends/communication/tests/test_comm.py
imports: import asyncio
  import multiprocessing
  import sys
  from typing import Union, List, Tuple, Type, Dict
  import numpy
  import pandas
  import pytest
  from .....lib.aio import AioEvent
  from .....tests.core import require_cudf, require_cupy
  from .....utils import get_next_port
  from ..None import SocketChannel, SocketServer, UnixSocketServer, DummyChannel, DummyServer, get_client_type, SocketClient, UnixSocketClient, DummyClient, Server
label_desc: Use image node_id 1 for calling a global function with example usage: _wrap_test(server_started_event, conf, tp) without return types