Method handler

tests/ctl/test_protocol.py:212–217

(reader, writer)

            socket_path = os.path.join(tmpdir, "test.sock")

            async def handler(reader, writer):
                msg = await ControlProtocol.read_message_async(reader)
                received.append(msg)
                await ControlProtocol.write_message_async(writer, data)
                writer.close()
                await writer.wait_closed()

            server = await asyncio.start_unix_server(handler, path=socket_path)