From 9ac0ebb0791851aea81ecc847802db5a39bfb6e7 Mon Sep 17 00:00:00 2001
From: Valentin Rothberg <rothberg@redhat.com>
Date: Tue, 5 Feb 2019 11:51:41 +0100
Subject: Cirrus: add vendor_check_task

* Make sure that all vendored dependencies are in sync with the code and
  the vendor.conf by running `make vendor` with a follow-up status check
  of the git tree.

* Vendor ginkgo and gomega to include the test dependencies.

Signed-off-by: Chris Evic <cevich@redhat.com>
Signed-off-by: Valentin Rothberg <rothberg@redhat.com>
---
 .../onsi/gomega/matchers/be_sent_matcher_test.go   | 107 +++++++++++++++++++++
 1 file changed, 107 insertions(+)
 create mode 100644 vendor/github.com/onsi/gomega/matchers/be_sent_matcher_test.go

(limited to 'vendor/github.com/onsi/gomega/matchers/be_sent_matcher_test.go')

diff --git a/vendor/github.com/onsi/gomega/matchers/be_sent_matcher_test.go b/vendor/github.com/onsi/gomega/matchers/be_sent_matcher_test.go
new file mode 100644
index 000000000..68ec72879
--- /dev/null
+++ b/vendor/github.com/onsi/gomega/matchers/be_sent_matcher_test.go
@@ -0,0 +1,107 @@
+package matchers_test
+
+import (
+	"time"
+
+	. "github.com/onsi/gomega/matchers"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+)
+
+var _ = Describe("BeSent", func() {
+	Context("when passed a channel and a matching type", func() {
+		Context("when the channel is ready to receive", func() {
+			It("should succeed and send the value down the channel", func() {
+				c := make(chan string)
+				d := make(chan string)
+				go func() {
+					val := <-c
+					d <- val
+				}()
+
+				time.Sleep(10 * time.Millisecond)
+
+				Expect(c).Should(BeSent("foo"))
+				Eventually(d).Should(Receive(Equal("foo")))
+			})
+
+			It("should succeed (with a buffered channel)", func() {
+				c := make(chan string, 1)
+				Expect(c).Should(BeSent("foo"))
+				Expect(<-c).Should(Equal("foo"))
+			})
+		})
+
+		Context("when the channel is not ready to receive", func() {
+			It("should fail and not send down the channel", func() {
+				c := make(chan string)
+				Expect(c).ShouldNot(BeSent("foo"))
+				Consistently(c).ShouldNot(Receive())
+			})
+		})
+
+		Context("when the channel is eventually ready to receive", func() {
+			It("should succeed", func() {
+				c := make(chan string)
+				d := make(chan string)
+				go func() {
+					time.Sleep(30 * time.Millisecond)
+					val := <-c
+					d <- val
+				}()
+
+				Eventually(c).Should(BeSent("foo"))
+				Eventually(d).Should(Receive(Equal("foo")))
+			})
+		})
+
+		Context("when the channel is closed", func() {
+			It("should error", func() {
+				c := make(chan string)
+				close(c)
+				success, err := (&BeSentMatcher{Arg: "foo"}).Match(c)
+				Expect(success).Should(BeFalse())
+				Expect(err).Should(HaveOccurred())
+			})
+
+			It("should short-circuit Eventually", func() {
+				c := make(chan string)
+				close(c)
+
+				t := time.Now()
+				failures := InterceptGomegaFailures(func() {
+					Eventually(c, 10.0).Should(BeSent("foo"))
+				})
+				Expect(failures).Should(HaveLen(1))
+				Expect(time.Since(t)).Should(BeNumerically("<", time.Second))
+			})
+		})
+	})
+
+	Context("when passed a channel and a non-matching type", func() {
+		It("should error", func() {
+			success, err := (&BeSentMatcher{Arg: "foo"}).Match(make(chan int, 1))
+			Expect(success).Should(BeFalse())
+			Expect(err).Should(HaveOccurred())
+		})
+	})
+
+	Context("when passed a receive-only channel", func() {
+		It("should error", func() {
+			var c <-chan string
+			c = make(chan string, 1)
+			success, err := (&BeSentMatcher{Arg: "foo"}).Match(c)
+			Expect(success).Should(BeFalse())
+			Expect(err).Should(HaveOccurred())
+		})
+	})
+
+	Context("when passed a nonchannel", func() {
+		It("should error", func() {
+			success, err := (&BeSentMatcher{Arg: "foo"}).Match("bar")
+			Expect(success).Should(BeFalse())
+			Expect(err).Should(HaveOccurred())
+		})
+	})
+})
-- 
cgit v1.2.3-54-g00ecf