- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestClosed (0.13 sec)
-
pkg/queue/instance_test.go
close(stop) }) select { case <-time.After(200 * time.Millisecond): t.Error("close stop, method exit timeout.") case <-signal: t.Log("queue return.") } } func TestClosed(t *testing.T) { t.Run("immediate close", func(t *testing.T) { stop := make(chan struct{}) q := NewQueue(0) go q.Run(stop) close(stop) if err := WaitForClose(q, 10*time.Second); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 3.4K bytes - Viewed (0)