close stream

sift-stack · Nov 15, 2024 · 52b2b5b · 52b2b5b
1 parent 359d271
commit 52b2b5b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/go/examples/ingestion/main.go b/go/examples/ingestion/main.go
@@ -109,6 +109,12 @@ func main() {
 			log.Println("ingested a log flow")
 		}
 	}
+
+	// Close the stream when finished and check if there are any errors
+	if _, err := siftStream.CloseAndRecv(); err != nil {
+		log.Fatalln(err)
+	}
+
 	log.Println("done.")
 }