(self)
| 333 | return hello |
| 334 | |
| 335 | async def _next_reply(self) -> dict[str, Any]: |
| 336 | reply = await self.receive_message(None) |
| 337 | self.more_to_come = reply.more_to_come |
| 338 | unpacked_docs = reply.unpack_response() |
| 339 | response_doc = unpacked_docs[0] |
| 340 | helpers_shared._check_command_response(response_doc, self.max_wire_version) |
| 341 | return response_doc |
| 342 | |
| 343 | @_handle_reauth |
| 344 | async def command( |
no test coverage detected