Return request_id, data, max_doc_size. :param message: (request_id, data, max_doc_size) or (request_id, data)
(
self, message: Union[tuple[int, Any], tuple[int, Any, int]]
)
| 366 | return self._pool |
| 367 | |
| 368 | def _split_message( |
| 369 | self, message: Union[tuple[int, Any], tuple[int, Any, int]] |
| 370 | ) -> tuple[int, Any, int]: |
| 371 | """Return request_id, data, max_doc_size. |
| 372 | |
| 373 | :param message: (request_id, data, max_doc_size) or (request_id, data) |
| 374 | """ |
| 375 | if len(message) == 3: |
| 376 | return message # type: ignore[return-value] |
| 377 | else: |
| 378 | # get_more and kill_cursors messages don't include BSON documents. |
| 379 | request_id, data = message # type: ignore[misc] |
| 380 | return request_id, data, 0 |
| 381 | |
| 382 | def __repr__(self) -> str: |
| 383 | return f"<{self.__class__.__name__} {self._description!r}>" |