NodePipeline/NodePipeline.Application/FileNameProvider.cs
2026-01-02 20:55:25 +03:00

20 lines
442 B
C#

using NodePipeline.Application.Nodes;
namespace NodePipeline.Application;
public class FileNameProvider : IFileNameProvider
{
private readonly Queue<string> _queue = [];
public string GetNextFileName()
{
return _queue.TryDequeue(out var filePath)
? filePath
: throw new Exception("Nothing to read");
}
public void AddNext(string filePath)
{
_queue.Enqueue(filePath);
}
}