diff --git a/main.go b/main.go
index 199cba2..0feba51 100644
--- a/main.go
+++ b/main.go
@@ -129,6 +129,7 @@ func main() {
 
 	// Pull price updates from RPC.
 	group.Go(func() error {
+		defer close(updates)
 		return client.StreamPriceAccounts(ctx, updates)
 	})