我正在使用 dockerclient https://github.com/samalba/dockerclient，它有一個基于通道的 API 來監(jiān)聽事件client.MonitorEvents()和一個方便的回調(diào)方法client.StartMonitorEvents(callbackHandler)。我想測試處理程序是否被調(diào)用。當然，dockerclient 在 goroutine 中處理事件?，F(xiàn)在，我的處理程序只是吐出一個日志。如果我在考試中等待，一切都會得到處理。如果我不這樣做，它會在處理任何事情之前退出：func eventCallback(event *dockerclient.Event, ec chan error, args ...interface{}) { log.Printf("Received event: %#v\n", *event)}我的測試似乎很簡單：func TestReceiveEvent(t *testing.T) { createAndMonitorEvents(server.URL) <- eventReady eventWriter.Write([]byte(someEvent)) // test for something here}當然，除非我time.Sleep()因為goroutine而放入a ，否則它不起作用。我如何告訴我的測試，“在運行測試之前等待其他例程完成它的工作”，而不是進入一些任意睡眠？我希望測試我的處理程序是否正確處理了該事件。備用接口client.MonitorEvents()返回一個通道，這給了我更大的控制權(quán)，但是通道的接收會吐出無限nil事件。
3 回答
慕的地6264312
TA貢獻1817條經(jīng)驗 獲得超6個贊
我認為當您使用nils 時MonitorEvents，您只會看到事件通道已關(guān)閉（包括 a的來源MonitorEventsclose(eventOrErrorChan)，支持這一點）。evt, ok := <-c讓您直接檢查它是否（ok關(guān)閉時為假），并for evt := range c在關(guān)閉后停止。通常，從關(guān)閉的通道接收被指定為“在接收到任何先前發(fā)送的值之后[產(chǎn)生]元素類型的零值”
關(guān)于等待回調(diào)的問題：回調(diào)可以關(guān)閉一個通道。（或發(fā)送給它。）然后您的測試可以等待指定的時間長度select：
select {
case <-c:
/* ...success... */
case <-time.After(5 * time.Second):
/* timed out */
}
如果您知道某些錯誤條件導(dǎo)致處理程序無法完成或無法運行，則它可能會在不同的通道上發(fā)出這些情況的信號，或者通過向 發(fā)送不同的值c。
弒天下
TA貢獻1818條經(jīng)驗 獲得超8個贊
“我如何告訴我的測試，“在運行測試之前等待其他例程完成它的工作”，而不是任意睡眠？”
您可以在頻道上發(fā)送或關(guān)閉頻道。調(diào)用者正在接收執(zhí)行塊，直到信號發(fā)生。我真的不明白如何將你的代碼處理成有意義的東西......你不能在函數(shù)中分配停止通道，你必須將它傳遞給函數(shù)以便調(diào)用者可以監(jiān)聽它。就像這甚至如何編譯？
func TestReceiveEvent(t *testing.T) {
createAndMonitorEvents(server.URL)
<- eventReady // undeclared variable, and discarding the event you recieved?
eventWriter.Write([]byte(someEvent)) //and another variable that is not declared
// test for something here
}
也許和想法會幫助你開始......
func createAndMonitorEvents(url string, done chan bool) {
//the codes
close(done)
}
func TestReceiveEvent(t *testing.T) {
eventReady := make(chan bool)
createAndMonitorEvents(server.URL, eventReady)
<- eventReady
eventWriter.Write([]byte(someEvent)) // dis still don't exist though
// test for something here
}
- 3 回答
- 0 關(guān)注
- 181 瀏覽
添加回答
舉報
0/150
提交
取消