add async
Brian Tiger Chow committed
Jan 22, 2015 at 01:46 UTC
d05bbb83c40c3985ad9d03240d5489ab212c0577
1 file changed
+2
-2
cmd/ipfswatch/main.go
+2
-2
@@ -118,7 +118,7 @@ func run(ipfsPath, watchPath string) error {
118
addTree(watcher, e.Name)
119
}
120
}
121
- func() {
121
+ proc.Go(func(p process.Process) {
122
file, err := os.Open(e.Name)
123
if err != nil {
124
log.Println(err)
@@ -129,7 +129,7 @@ func run(ipfsPath, watchPath string) error {
129
log.Println(err)
130
}
131
log.Printf("added %s... key: %s", e.Name, k)
132
- }()
132
+ })
133
}
134
case err := <-watcher.Errors:
135
log.Println(err)