code: def stream(self, entity, callback):
          
          with self._lock:
              self._stream(entity, callback)
docs: Stream out all eligible children of the input entity.
  
          :param entity: The target entity to be streamed.
          :param callback: The function that takes the node and
              actually send it out.