From e85a2d25a14f20abfa40193ab8b67bf891eaa363 Mon Sep 17 00:00:00 2001
From: Bel LaPointe <153096461+breel-render@users.noreply.github.com>
Date: Mon, 15 Apr 2024 13:18:14 -0600
Subject: [PATCH] queue from Dequeue to Syn for SynAck

---
 queue.go      | 6 +++---
 queue_test.go | 8 ++++----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/queue.go b/queue.go
index f766d32..446defd 100644
--- a/queue.go
+++ b/queue.go
@@ -35,9 +35,9 @@ func (q Queue) Enqueue(ctx context.Context, b []byte) error {
 	return err
 }
 
-func (q Queue) Dequeue(ctx context.Context) (string, []byte, error) {
+func (q Queue) Syn(ctx context.Context) (string, []byte, error) {
 	for {
-		reservation, m, err := q.dequeue(ctx)
+		reservation, m, err := q.syn(ctx)
 		if reservation != nil || err != nil {
 			return string(reservation), m, err
 		}
@@ -50,7 +50,7 @@ func (q Queue) Dequeue(ctx context.Context) (string, []byte, error) {
 	}
 }
 
-func (q Queue) dequeue(ctx context.Context) ([]byte, []byte, error) {
+func (q Queue) syn(ctx context.Context) ([]byte, []byte, error) {
 	now := time.Now().Unix()
 	reservation := []byte(uuid.New().String())
 	var payload []byte
diff --git a/queue_test.go b/queue_test.go
index 924538b..25edb68 100644
--- a/queue_test.go
+++ b/queue_test.go
@@ -25,13 +25,13 @@ func TestQueue(t *testing.T) {
 		}
 	})
 
-	t.Run("dequeue", func(t *testing.T) {
+	t.Run("syn ack", func(t *testing.T) {
 		found := map[string]struct{}{}
 		for i := 0; i < 39; i++ {
-			if reservation, b, err := q.Dequeue(ctx); err != nil {
-				t.Fatal(i, "dequeue err", err)
+			if reservation, b, err := q.Syn(ctx); err != nil {
+				t.Fatal(i, "syn err", err)
 			} else if _, ok := found[string(b)]; ok {
-				t.Errorf("dequeued %q twice (%+v)", b, found)
+				t.Errorf("syn'd %q twice (%+v)", b, found)
 			} else if err := q.Ack(ctx, reservation); err != nil {
 				t.Fatal(i, "failed to ack", err)
 			} else {