Workers.cs

Workers.cs

// add to di singleton
    public class Workers
    {
        private ConcurrentBag<IDataflowBlock> Actions { get; set; } = new ConcurrentBag<IDataflowBlock>();

        public ActionBlock<TInput> AddWork<TInput>(Func<TInput, Task> work) where TInput : class, new()
        {
            var action = new ActionBlock<TInput>(work);
            Actions.Add(action);

            return action;
        }

        public ActionBlock<TInput> AddWork<TInput>(Action<TInput> work) where TInput : class, new()
        {
            var action = new ActionBlock<TInput>(work);
            Actions.Add(action);

            return action;
        }

        public ActionBlock<TInput> AddWork<TInput>(Func<TInput, Task> work, ExecutionDataflowBlockOptions dataflowBlockOptions) where TInput : class, new()
        {
            var action = new ActionBlock<TInput>(work, dataflowBlockOptions);
            Actions.Add(action);

            return action;
        }

        public ActionBlock<TInput> AddWork<TInput>(Action<TInput> work, ExecutionDataflowBlockOptions dataflowBlockOptions) where TInput : class, new()
        {
            var action = new ActionBlock<TInput>(work, dataflowBlockOptions);
            Actions.Add(action);

            return action;
        }
    }