可观察以定期处理目录中的文件

我正在尝试生成一系列事件，这些事件由目录中现有文件的文件名组成。

这很有效。代码是这样的：

Observable.Generate(
                        ExistingFiles(path, filter),
                        Condition(),
                        Iterate(),
                        CreateFileChangedEvent()
                        )
           private static Func<List<string>.Enumerator, FileChangedEvent> CreateFileChangedEvent()
            {
                return enumerator => new FileChangedEvent(enumerator.Current, @"Existing");
            }
            private static Func<List<string>.Enumerator, List<string>.Enumerator> Iterate()
            {
                return enumerator =>
                {
                    enumerator.MoveNext();
                    return enumerator;
                };
            }
            private static List<string>.Enumerator ExistingFiles(string path, string filter)
            {
                List<string>.Enumerator files =
                    Directory.GetFiles(path, filter)
                    .ToList()
                    .GetEnumerator();
                // Advance the enumerator to the first result
                files.MoveNext();
                return files;
            }
            private static Func<List<string>.Enumerator, bool> Condition()
            {
                return enumerator => enumerator.Current != null;
            }
        }

我想将此可观察量

包装在另一个可观察量中，该可观察量将按时间触发文件枚举。我对重复/重播的所有尝试都不会触发文件搜索并生成以前的事件，这不是我想要的。

提前谢谢。

编辑 1 ：好吧，代码可以使用ToObservable((简化

Directory.GetFiles(path, filter)
    .ToObservable()
    .Select(s => new FileChangedEvent(s, @"Existing"))

  Observable.Interval(TimeSpan.FromSeconds(2))
    .Select(_ => 
      Directory.GetFiles(path, filter)
     .ToObservable()
     .Select(s => new FileChangedEvent(s, @"Existing"))
   )
   .SelectMany(_ => _)
   .Subscribe(onNewFileChangedEvent => {
     Console.WriteLine(onNewFileChangedEvent.ToString());
   });

   t1--t2--t3
   '    '   '
    '     '   ---t3{evt1,evt2,evt3}
     '      ---t{evt1,evt2,evt3}
      ---t1{evt1,evt2,evt3}