diff options
Diffstat (limited to 'queue_test.go')
| -rw-r--r-- | queue_test.go | 37 |
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 |