def stream(self, data):
        """
        Runs a textractor pipeline and streams extracted content from a data directory.

        Args:
            data: input data directory
        """

        # Stream sections from content
        for sections in self.extract(glob(f"{data}/**/*", recursive=True)):
            yield from sections

        Runs a textractor pipeline and streams extracted content from a data directory.

        Args:
            data: input data directory
        
txtairag/rag.py