Set the batch processing function Args: processor_func: Function that takes list of request data and returns list of responses
(self, processor_func)
| 219 | req.future.set_exception(BatchingError(error_msg)) |
| 220 | |
| 221 | def set_processor(self, processor_func): |
| 222 | """ |
| 223 | Set the batch processing function |
| 224 | |
| 225 | Args: |
| 226 | processor_func: Function that takes list of request data and returns list of responses |
| 227 | """ |
| 228 | self._processor_func = processor_func |
| 229 | |
| 230 | def add_request(self, request_data: Dict[str, Any]) -> Dict[str, Any]: |
| 231 | """ |
no outgoing calls