summaryrefslogtreecommitdiff
path: root/vendor/github.com/onsi/ginkgo/integration/_fixtures/synchronized_setup_tests/synchronized_setup_tests_suite_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/onsi/ginkgo/integration/_fixtures/synchronized_setup_tests/synchronized_setup_tests_suite_test.go')
-rw-r--r--vendor/github.com/onsi/ginkgo/integration/_fixtures/synchronized_setup_tests/synchronized_setup_tests_suite_test.go43
1 files changed, 43 insertions, 0 deletions
diff --git a/vendor/github.com/onsi/ginkgo/integration/_fixtures/synchronized_setup_tests/synchronized_setup_tests_suite_test.go b/vendor/github.com/onsi/ginkgo/integration/_fixtures/synchronized_setup_tests/synchronized_setup_tests_suite_test.go
new file mode 100644
index 000000000..b734854ee
--- /dev/null
+++ b/vendor/github.com/onsi/ginkgo/integration/_fixtures/synchronized_setup_tests/synchronized_setup_tests_suite_test.go
@@ -0,0 +1,43 @@
+package synchronized_setup_tests_test
+
+import (
+ . "github.com/onsi/ginkgo"
+ . "github.com/onsi/gomega"
+
+ "fmt"
+ "testing"
+ "time"
+)
+
+func TestSynchronized_setup_tests(t *testing.T) {
+ RegisterFailHandler(Fail)
+ RunSpecs(t, "Synchronized_setup_tests Suite")
+}
+
+var beforeData string
+
+var _ = SynchronizedBeforeSuite(func() []byte {
+ fmt.Printf("BEFORE_A_%d\n", GinkgoParallelNode())
+ time.Sleep(100 * time.Millisecond)
+ return []byte("DATA")
+}, func(data []byte) {
+ fmt.Printf("BEFORE_B_%d: %s\n", GinkgoParallelNode(), string(data))
+ beforeData += string(data) + "OTHER"
+})
+
+var _ = SynchronizedAfterSuite(func() {
+ fmt.Printf("\nAFTER_A_%d\n", GinkgoParallelNode())
+ time.Sleep(100 * time.Millisecond)
+}, func() {
+ fmt.Printf("AFTER_B_%d\n", GinkgoParallelNode())
+})
+
+var _ = Describe("Synchronized Setup", func() {
+ It("should run the before suite once", func() {
+ Ω(beforeData).Should(Equal("DATAOTHER"))
+ })
+
+ It("should run the before suite once", func() {
+ Ω(beforeData).Should(Equal("DATAOTHER"))
+ })
+})