IProducerConsumerBuffer.cs

Go to the documentation of this file.

using System;
using System.Threading;
 
namespace AnalyzeRe.LargeDataUpload
{
    public interface IProducerConsumerBuffer<out TProduced> : IDisposable
    {
        bool IsRunning { get; }
 
        bool CanTake { get; }
 
        void Start(CancellationToken? cancellationToken = null);
 
        void Cancel();
 
        TProduced TryTake(out bool success, CancellationToken? cancellation);
    }
}