From 9ad0f9bb2bdfe47f144e2a0e8951dcfe6344a4ea Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sat, 24 Aug 2024 16:58:01 -0400
Subject: Queue

---
 queue_test.go | 37 +++++++++++++++++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100644 queue_test.go

(limited to 'queue_test.go')

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
-- 
cgit v1.2.3