我根据我的要求扩展了以下代码。https://github.com/radovskyb/watcher/blob/master/example/basics/main.go
此代码的目的是监视某些事件(CREATE、WRITE)并据此采取适当的行动。为了测试这段代码,我使用了 Ginkgo 和 Gomega,这就是我寻求帮助的地方。
我正在尝试测试以下代码和平(也在链接中提供),我不确定我应该如何进行。
go func() {
for {
select {
case event := <-w.Event:
fmt.Println(event) // Print the event's info.
case err := <-w.Error:
log.Fatalln(err)
case <-w.Closed:
return
}
}
}()
我检查了一下,Gomega 支持支持“通道”的异步测试,但我尝试了几件事,但最终初始化了需要触发实际事件进行测试的新观察者对象。我试图创建“tempDir”,这样我就可以触发 CRETE / WRITE 事件,然后关闭通道,但它没有帮助,在运行这个特定的测试之后,它只是等待通道关闭。
w := watcher.New()
w.FilterOps(watcher.Create, watcher.Write)
dir, err := ioutil.TempDir("", "watcher2")
Expect(err).To(BeNil())
defer os.RemoveAll(dir)
tmpfile := filepath.Join(dir, "watcherremoved")
err = ioutil.WriteFile(tmpfile, []byte("init"), 0666)
Expect(err).To(BeNil())
event := <-w.Event
Eventually(event.Path).Should(Equal(ADMIN_VAULT))
<-w.Closed