Lines Matching refs:await

24         await super().setup_connection()
27         await self._set_mode(cur_mode)
32             await self.writer.drain()
33             l = await self.reader.readline()
38         return await self._send_wrapper(proc)
42             r = await self.send_stream("END")
46             r = await self.send_message({"get-stream": None})
57         await self._set_mode(self.MODE_GET_STREAM)
58         r = await self.send_stream("%s %s" % (method, taskhash))
64         await self._set_mode(self.MODE_NORMAL)
70         return await self.send_message({"report": m})
73         await self._set_mode(self.MODE_NORMAL)
78         return await self.send_message({"report-equiv": m})
81         await self._set_mode(self.MODE_NORMAL)
82         return await self.send_message(
87         await self._set_mode(self.MODE_NORMAL)
88         return await self.send_message(
93         await self._set_mode(self.MODE_NORMAL)
94         return await self.send_message({"get-stats": None})
97         await self._set_mode(self.MODE_NORMAL)
98         return await self.send_message({"reset-stats": None})
101         await self._set_mode(self.MODE_NORMAL)
102         return (await self.send_message({"backfill-wait": None}))["tasks"]