toAnalyzerStream method

Stream<WatchEvent> toAnalyzerStream()

Implementation

Stream<WatchEvent> toAnalyzerStream() async* {
  await for (final event in this) {
    final type = switch (event.type) {
      io.FileSystemEvent.create => ChangeType.ADD,
      io.FileSystemEvent.modify => ChangeType.MODIFY,
      io.FileSystemEvent.delete => ChangeType.REMOVE,
      io.FileSystemEvent.move => ChangeType.MODIFY,
      _ => throw UnimplementedError(),
    };
    yield WatchEvent(type, event.path);
  }
}