use StoppableWorkers in part of constructor

viamrobotics · Jan 22, 2025 · 3a5e3c7 · 3a5e3c7
1 parent 8fd687a
commit 3a5e3c7
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/rpc/wrtc_call_queue_mongodb.go b/rpc/wrtc_call_queue_mongodb.go
@@ -227,9 +227,7 @@ func NewMongoDBWebRTCCallQueue(
 	startOnce := make(chan struct{})
 	var startOnceSync sync.Once
 
-	queue.activeBackgroundWorkers.Add(1) // TODO(RSDK-866): remove
-	utils.ManagedGo(func() {             // TODO(RSDK-866): remove
-		// queue.activeStoppableWorkers.Add(func(ctx context.Context) {
+	queue.activeStoppableWorkers.Add(func(ctx context.Context) {
 		defer queue.csManagerSeq.Add(1) // helpful on panicked restart
 		select {
 		case <-queue.cancelCtx.Done():
@@ -241,7 +239,7 @@ func NewMongoDBWebRTCCallQueue(
 			})
 			queue.subscriptionManager(newState.ChangeStream)
 		}
-	}, queue.activeBackgroundWorkers.Done)
+	})
 
 	select {
 	case <-queue.cancelCtx.Done():