diff --git a/pkg/service/roomservice.go b/pkg/service/roomservice.go
index c81274093..d59d3ce82 100644
--- a/pkg/service/roomservice.go
+++ b/pkg/service/roomservice.go
@@ -84,8 +84,8 @@ func (s *RoomService) CreateRoom(ctx context.Context, req *livekit.CreateRoomReq
 	if err != nil {
 		return nil, err
 	}
-	sink.Close()
-	source.Close()
+	defer sink.Close()
+	defer source.Close()
 
 	// ensure it's created correctly
 	err = s.confirmExecution(func() error {