diff --git a/server/stream.go b/server/stream.go
index 2e202989f..6dd19a9ba 100644
--- a/server/stream.go
+++ b/server/stream.go
@@ -78,7 +78,7 @@ func EventStreamSSE(c *gin.Context) {
 
 	go func() {
 		// TODO remove this from global config
-		Config.Services.Pubsub.Subscribe(c, "topic/events", func(m pubsub.Message) {
+		Config.Services.Pubsub.Subscribe(ctx, "topic/events", func(m pubsub.Message) {
 			name := m.Labels["repo"]
 			priv := m.Labels["private"]
 			if repo[name] || priv == "false" {