Method WaitForN

proxy/proxy_test.go:126–141

(exp string, n int, to time.Duration)

}

func (l *testLog) WaitForN(exp string, n int, to time.Duration) error {
	timeout := time.After(to)
	ticker := time.NewTicker(10 * time.Millisecond)
	defer ticker.Stop()

	for {
		select {
		case <-timeout:
			return fmt.Errorf("timeout waiting for log entry: %s", exp)
		case <-ticker.C:
			if l.Count(exp) >= n {
				return nil
			}
		}
	}
}

func (l *testLog) WaitFor(exp string, to time.Duration) error {
	return l.WaitForN(exp, 1, to)