async def METHOD_NAME(self):
    ADDRESS = r'\\.\pipe\_test_pipe-%s' % os.getpid()
    with self.assertRaises(FileNotFoundError):
        await self.loop.create_pipe_connection(
            asyncio.Protocol, ADDRESS)
    [server] = await self.loop.start_serving_pipe(
        UpperProto, ADDRESS)
    self.assertIsInstance(server, windows_events.PipeServer)
    clients = []
    for i in range(5):
        stream_reader = asyncio.StreamReader(loop=self.loop)
        protocol = asyncio.StreamReaderProtocol(stream_reader,
                                                loop=self.loop)
        trans, proto = await self.loop.create_pipe_connection(
            lambda: protocol, ADDRESS)
        self.assertIsInstance(trans, asyncio.Transport)
        self.assertEqual(protocol, proto)
        clients.append((stream_reader, trans))
    for i, (r, w) in enumerate(clients):
        w.write('lower-{}\n'.format(i).encode())
    for i, (r, w) in enumerate(clients):
        response = await r.readline()
        self.assertEqual(response, 'LOWER-{}\n'.format(i).encode())
        w.close()
    server.close()
    with self.assertRaises(FileNotFoundError):
        await self.loop.create_pipe_connection(
            asyncio.Protocol, ADDRESS)
    return 'done'