files.service: fixed

This commit is contained in:
Alexey Bannov 2023-02-03 10:06:10 +03:00
parent 406bbd81cc
commit 480962405a

View File

@ -117,7 +117,7 @@ public class Startup : BaseWorkerStartup
boundedChannelCapacity = 100;
}
services.AddSingleton(Channel.CreateBounded<IEnumerable<FileData<int>>>(new BoundedChannelOptions(boundedChannelCapacity) { SingleReader = true, SingleWriter = true }));
services.AddSingleton(Channel.CreateBounded<IEnumerable<FileData<int>>>(new BoundedChannelOptions(boundedChannelCapacity) { SingleReader = true, SingleWriter = false }));
services.AddSingleton(svc => svc.GetRequiredService<Channel<IEnumerable<FileData<int>>>>().Reader);
services.AddSingleton(svc => svc.GetRequiredService<Channel<IEnumerable<FileData<int>>>>().Writer);
}