diff --git a/main.go b/main.go index 6e2bbbf..2570db7 100644 --- a/main.go +++ b/main.go @@ -66,6 +66,15 @@ func main() { }) filesByGroup := channel.FlatMap(groupedFiles, func(key string, _ struct{}) string { return key }) + + filesByGroup = channel.MapSuccessive(filesByGroup, func(s string) string { + fmt.Println("GROUPED", s) + fmt.Println("EXISTS", Exists(s)) + fmt.Println("SymlinkFilesOnly", SymlinkFilesOnly(s)) + fmt.Println("VideosOnly", VideosOnly(s)) + return s + }) + filteredFiles := channel.Filter(filesByGroup, Or(Not(Exists), And(SymlinkFilesOnly, VideosOnly))) filteredFiles = channel.MapSuccessive(filteredFiles, func(s string) string {