More queue unit testing

This commit is contained in:
Philip O'Toole
2022-05-23 13:05:35 -04:00
parent 2764bd7600
commit 78c038e24d

View File

@@ -253,6 +253,9 @@ func Test_NewQueueWriteNilSingleChan(t *testing.T) {
if req.Statements != nil {
t.Fatalf("statements slice is not nil")
}
if len(req.flushChans) != 1 && req.flushChans[0] != fc {
t.Fatalf("flush chans is not correct")
}
req.Close()
case <-time.NewTimer(5 * time.Second).C:
t.Fatalf("timed out waiting for statement")