-
Notifications
You must be signed in to change notification settings - Fork 0
/
FileReader.cs
38 lines (31 loc) · 949 Bytes
/
FileReader.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConcurrentEx
{
public class FileReader : Processor
{
private BlockingCollection<string> _sentenceQueue;
private string _pathToFile;
public FileReader(BlockingCollection<string> sentenceQueue, string pathToFile)
{
_sentenceQueue = sentenceQueue;
_pathToFile = pathToFile;
}
protected override async Task StartProcessing()
{
using StreamReader reader = File.OpenText(_pathToFile);
string line;
while ((line = await reader.ReadLineAsync()) is not null)
{
_sentenceQueue.Add(line);
}
_sentenceQueue.CompleteAdding();
Console.WriteLine("DONE reading file");
}
}
}