我很好奇IEnumerable与IObservable的不同之处.我分别理解了pull和push模式,但是C#在内存等方面如何通知订阅者(对于IObservable)它应该在内存中接收下一位数据来处理？观察到的实例如何知道它有一个数据的变化推送到订阅者.
我的问题来自于我正在从文件中读取行的测试.该文件总共约为6Mb.
标准时间：4.7s,行：36587
Rx拍摄时间：0.68秒,行数：36587
Rx如何能够大量改进文件中每条线的正常迭代？
private static void ReadStandardFile()
{
var timer = Stopwatch.StartNew();
var linesProcessed = 0;
foreach (var l in ReadLines(new FileStream(_filePath,FileMode.Open)))
{
var s = l.Split(',');
linesProcessed++;
}
timer.Stop();
_log.DebugFormat("Standard Time Taken: {0}s,lines: {1}",timer.Elapsed.ToString(),linesProcessed);
}
private static void ReadRxFile()
{
var timer = Stopwatch.StartNew();
var linesProcessed = 0;
var query = ReadLines(new FileStream(_filePath,FileMode.Open)).ToObservable();
using (query.Subscribe((line) =>
{
var s = line.Split(',');
linesProcessed++;
}));
timer.Stop();
_log.DebugFormat("Rx Time Taken: {0}s,linesProcessed);
}
private static IEnumerable<string> ReadLines(Stream stream)
{
using (StreamReader reader = new StreamReader(stream))
{
while (!reader.EndOfStream)
yield return reader.ReadLine();
}
}
