iter_receive() -> (typecode, item) iterate while the query returns items. typecode list is in https://docs.basex.org/wiki/Server_Protocol:_Types
(self)
| 232 | return self.recv_c_str() |
| 233 | |
| 234 | def iter_receive(self): |
| 235 | """iter_receive() -> (typecode, item) |
| 236 | |
| 237 | iterate while the query returns items. |
| 238 | typecode list is in https://docs.basex.org/wiki/Server_Protocol:_Types |
| 239 | """ |
| 240 | result = list() |
| 241 | self.__swrapper.clear_buffer() |
| 242 | typecode = self.__swrapper.recv_single_byte() |
| 243 | while typecode > 0: |
| 244 | result.append(self.__swrapper.recv_until_terminator()) |
| 245 | typecode = self.__swrapper.recv_single_byte() |
| 246 | if not self.server_response_success(): |
| 247 | raise IOError(self.recv_c_str()) |
| 248 | for ba in result: |
| 249 | yield ba.decode(self.__swrapper.receive_bytes_encoding) |
| 250 | |
| 251 | |
| 252 | # --------------------------------- |
no test coverage detected