def __init__(self, data_dir, callback):
        self.callback = callback

        # Now setup dynamic monitoring of the data directory
        observer = Observer()
        observer.schedule(self, path=data_dir)
        observer.start()
Initialization
dataset/ETHPy150Open SuperCowPowers/workbench/workbench/utils/pcap_streamer.py/DirWatcher.__init__