fromfile_flow.eventsimportFileSystemEventfromfile_flow.ioimportTextIO,IOContainerfromfile_flow.pipelineimportPipelinefromfile_flow.operationimportOperatorfromfile_flow.watcherimportWatcherfromfile_flow.handlerimportPatternHandlerhandler=PatternHandler(patterns={"*.txt":IOContainer(TextIO(),TextIO())},pipelines={FileSystemEvent: [Pipeline([Operator(lambdadata:print(data))])]})watcher=Watcher(root="demo",handler=handler)watcher.run()