docs: def _send_chunk(self, index, chunk):
          """Send the current chunk to the workers for processing.
          Called when the _partial_chunk is complete.
  
          Blocks when the outbox is full.
          """
          self._pending_chunks += 1
          self.outbox.put((index, chunk))