Method WaitFor

internal/testutil/server.go:292–305

WaitFor polls until predicate returns true or the timeout expires. Returns the captured list at the moment predicate first matched (or the last seen list on timeout). Tests typically call Tick(ctx) on the worker once then WaitFor(..., 0) for an immediate check; the timeout exists for cases where the

(t *testing.T, timeout time.Duration, predicate func([]SubscriberCaptured) bool)

// the worker once then WaitFor(..., 0) for an immediate check; the
// timeout exists for cases where the publisher may still be in flight.
func (s *SubscriberReceiverResult) WaitFor(t *testing.T, timeout time.Duration, predicate func([]SubscriberCaptured) bool) []SubscriberCaptured {
	t.Helper()
	deadline := time.Now().Add(timeout)
	for {
		got := s.Captured()
		if predicate(got) {
			return got
		}
		if time.Now().After(deadline) {
			return got
		}
		time.Sleep(20 * time.Millisecond)
	}
}

// SubscriberReceiver returns a multi-path HTTP receiver wired for the
// new webhook-resource envelope. Routes work as plain paths under the