IMpscChannel.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace Pole.Core.Channels
{
    public interface IMpscChannel<T> : IBaseMpscChannel
    {
        void BindConsumer(Func<List<T>, Task> consumer);
        void BindConsumer(Func<List<T>, Task> consumer, int maxBatchSize, int maxMillisecondsDelay);
        void Config(int maxBatchSize, int maxMillisecondsDelay);
        ValueTask<bool> WriteAsync(T data);
    }
}