Function timeout

queues/testutils_test.go:14–24

()

)

func timeout() chan int {
	done := make(chan int)
	go func() {
		select {
		case <-time.After(testTimeout):
			panic("Timeout")
		case <-done:
		}
	}()
	return done
}

func testReturn(t *testing.T, got interface{}, wasOk bool, expected interface{}, expectedOk bool) {
	if wasOk != expectedOk {