Queuev0.2.0

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