// See the License for the specific language governing permissions and
// limitations under the License.

package sleep

import (
	"testing"
	"time"

	"istio.io/istio/pkg/test/util/assert"
)

func TestUntil(t *testing.T) {
	c := make(chan struct{})
	assert.Equal(t, Until(c, time.Millisecond), true)

	go func() {
		time.Sleep(time.Millisecond * 50)
		close(c)
	}()
	assert.Equal(t, Until(c, time.Minute), false)

	"errors"
	"fmt"
	"math/rand"
	"sync"
	"sync/atomic"
	"testing"
	"time"

	"k8s.io/apimachinery/pkg/util/runtime"
	"k8s.io/utils/clock"
	testingclock "k8s.io/utils/clock/testing"
)

func TestUntil(t *testing.T) {
	ch := make(chan struct{})
	close(ch)
	Until(func() {
		t.Fatal("should not have been invoked")
	}, 0, ch)

	ch = make(chan struct{})
	called := make(chan struct{})
	go func() {