refactor

Author: hariso

pkg/inspector/inspector_test.go

@@ -93,14 +93,9 @@ func TestInspector_Send_SessionCtxCanceled(t *testing.T) {
 	assertGotRecord(is.New(t), s, r)
 
 	cancel()
-	time.Sleep(100 * time.Millisecond)
 
-	select {
-	case _, ok := <-s.C:
-		is.True(!ok) // expected no record
-	default:
-		is.Fail() // expected channel to be closed
-	}
+	_, got, _ := cchan.Chan[record.Record](s.C).RecvTimeout(context.Background(), 100*time.Millisecond)
+	is.True(!got) // expected no record
 }
 
 func TestInspector_Send_SlowConsumer(t *testing.T) {