Method reset

python/dgl/graphbolt/base.py:431–433

Resets the state of the datapipe.

(self)

        self.buffer = deque(maxlen=buffer_size)

    def reset(self):
        """Resets the state of the datapipe."""
        self.buffer.clear()


@functional_datapipe("wait")