From acac2a60b09a434e2d872a36a081f181950706b7 Mon Sep 17 00:00:00 2001
From: Bel LaPointe <153096461+breel-render@users.noreply.github.com>
Date: Mon, 15 Apr 2024 14:19:53 -0600
Subject: [PATCH] finish ingest loop

---
 ingest.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/ingest.go b/ingest.go
index 85b6b1b..3f07f58 100644
--- a/ingest.go
+++ b/ingest.go
@@ -23,7 +23,7 @@ func (i Ingester) Process(ctx context.Context) error {
 	ctx, can := context.WithCancel(ctx)
 	defer can()
 
-	for {
+	for ctx.Err() == nil {
 		reservation, read, err := i.reader.Syn(ctx)
 		if err != nil {
 			return err
@@ -39,4 +39,6 @@ func (i Ingester) Process(ctx context.Context) error {
 			return err
 		}
 	}
+
+	return ctx.Err()
 }