code: def async_pull(self, src, index, offset, count):
      self._pull_index = (self._pull_index + 1) % self.pool_size
      pull_data = (self._pull_index, src, index, offset, count)
      self._pull_queue.append(pull_data)
      if len(self._pull_queue) <= self.pool_size:
          self._async_pull(self._pull_index, src, index, offset, count)
  
imports: import numpy
  import paddle
  from paddle.framework import core
  from paddle.device import cuda
  from pgl.utils.logger import log
label_desc: Use image node_id 7 for calling the StreamPool obj's underlying member method code with example usage: obj.async_pull(src, index, offset, count) without return types