(self, result, bucket)
| 226 | """Mixin for backends that enables the async API.""" |
| 227 | |
| 228 | def _collect_into(self, result, bucket): |
| 229 | self.result_consumer.buckets[result] = bucket |
| 230 | |
| 231 | def iter_native(self, result, no_ack=True, **kwargs): |
| 232 | self._ensure_not_eager() |