deregister psrpc topics (#251)

livekit · Apr 11, 2024 · aa8cc68 · aa8cc68
1 parent fa49a5e
commit aa8cc68
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/service/service.go b/pkg/service/service.go
@@ -536,10 +536,10 @@ func RegisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.I
 
 func DeregisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo) {
 	server.DeregisterUpdateIngressTopic(info.IngressId)
-	server.RegisterDeleteIngressTopic(info.IngressId)
+	server.DeregisterDeleteIngressTopic(info.IngressId)
 
 	if info.InputType == livekit.IngressInput_WHIP_INPUT {
-		server.RegisterDeleteWHIPResourceTopic(info.State.ResourceId)
+		server.DeregisterDeleteWHIPResourceTopic(info.State.ResourceId)
 	}
 }