Function tick

internal/e2e/webhooks_e2e_test.go:192–198

tick drains the subscriber worker once. Tests call this between trigger and assertion so they don't wait on the 30s production tick.

(t *testing.T, ts *testutil.E2ATestServer)

// tick drains the subscriber worker once. Tests call this between
// trigger and assertion so they don't wait on the 30s production tick.
func tick(t *testing.T, ts *testutil.E2ATestServer) {
	t.Helper()
	// publishAsync uses a goroutine — give it a beat to land the
	// delivery row before we drain.
	time.Sleep(50 * time.Millisecond)
	ts.SubscriberWorker.Tick(context.Background())
}

// ----------------------------------------------------------------------
// P1 — Outbound events