EventSinks.cs

using System.Threading.Tasks;
 
namespace Waher.Events.Filter
{
    public class EventSinks : EventSink
    {
        private readonly IEventSink[] sinks;
        private readonly int nrSinks;
 
        public EventSinks(string ObjectID, params IEventSink[] Sinks)
            : base(ObjectID)
        {
            this.sinks = Sinks;
            this.nrSinks = this.sinks?.Length ?? 0;
        }
 
        public override Task Queue(Event Event)
        {
            Task[] Tasks = new Task[this.nrSinks];
            int i;
 
            for (i = 0; i < this.nrSinks; i++)
                Tasks[i] = this.sinks[i].Queue(Event);
 
            return Task.WhenAll(Tasks);
        }
    }
}