(self, datagram: bytes, is_end=False)
| 57 | raise dns.exception.Timeout |
| 58 | |
| 59 | async def send(self, datagram: bytes, is_end=False): |
| 60 | l = len(datagram) |
| 61 | data = struct.pack("!H", l) + datagram |
| 62 | await self.connection.write(self.stream_id, data, is_end) |
| 63 | |
| 64 | async def add_input(self, data: bytes, is_end: bool): |
| 65 | self.buffer.put(data, is_end) |