TEAMModelOS/TEAMModelOS.Service/Services/ChangeFeed/KnowledgeChangeFeed.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using TEAMModelOS.SDK.Helper.Common.JsonHelper;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.Service.Models;

namespace TEAMModelOS.Service.Services.ChangeFeed
{
    public class KnowledgeChangeFeed : IChangeFeedService<Knowledge>, IChangeService
    {
        private AzureCosmosFactory cosmosDBV3Repository;
        public KnowledgeChangeFeed(AzureCosmosFactory azureCosmos) {
            cosmosDBV3Repository = azureCosmos;
        }
        public   void Processor(IReadOnlyCollection<Knowledge> changes)
        {
            //List<Knowledge> s = await cosmosDBV3Repository.FindAll<Knowledge>();
            Console.WriteLine(DateTimeOffset.Now.UtcTicks +"    "+changes.ToApiJson());
        }
    }
}