receive does not support closed ch

mafredri · mafredri · commit 026b63ef17c0 · 2025-05-06T14:09:55.000+03:00
diff --git a/agent/agentssh/agentssh_test.go b/agent/agentssh/agentssh_test.go
@@ -214,7 +214,11 @@ func TestNewServer_CloseActiveConnections(t *testing.T) {
 		}
 
 		for _, ch := range waitConns {
-			testutil.RequireReceive(ctx, t, ch)
+			select {
+			case <-ctx.Done():
+				t.Fatal("timeout")
+			case <-ch:
+			}
 		}
 
 		return s, wg.Wait

Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,11 @@ func TestNewServer_CloseActiveConnections(t *testing.T) {`
`214`	`214`	`}`
`215`	`215`
`216`	`216`	`for _, ch := range waitConns {`
`217`		`- testutil.RequireReceive(ctx, t, ch)`
	`217`	`+ select {`
	`218`	`+ case <-ctx.Done():`
	`219`	`+ t.Fatal("timeout")`
	`220`	`+ case <-ch:`
	`221`	`+ }`
`218`	`222`	`}`
`219`	`223`
`220`	`224`	`return s, wg.Wait`