summaryrefslogtreecommitdiffstats
path: root/queue_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'queue_test.go')
-rw-r--r--queue_test.go37
1 files changed, 37 insertions, 0 deletions
diff --git a/queue_test.go b/queue_test.go
new file mode 100644
index 0000000..33666d8
--- /dev/null
+++ b/queue_test.go
@@ -0,0 +1,37 @@
+package share_test
+
+import (
+ "testing"
+
+ "git.samanthony.xyz/share"
+)
+
+func TestQueue(t *testing.T) {
+ q := share.NewQueue[string]()
+
+ vals := []string{"foo", "bar", "baz", "xyz"}
+
+ go func() {
+ for _, v := range vals {
+ q.Enqueue <- v
+ }
+ close(q.Enqueue)
+ }()
+
+ go func() {
+ i := 0
+ for front := range q.Dequeue {
+ t.Log("received", front, "from queue")
+ if i > len(vals)-1 {
+ t.Fatal("received too many elements from queue")
+ }
+ if front != vals[i] {
+ t.Fatalf("received %v from queue; wanted %v", front, vals[i])
+ }
+ i++
+ }
+ if i < len(vals) {
+ t.Fatal("did not receive enough values from queue")
+ }
+ }()
+} \ No newline at end of file