向任何文本阅读器添加功能

我同意创建一个实现 TextReader ,将实现委托给底层 特克斯特雷德 并且增加了一些对位置跟踪的额外支持是一种很好的方法。你可以认为这是 Decorator pattern 因为你在装饰 特克斯特雷德 用一些附加功能初始化。

更好的包装: 你可以用一种更简单的方式来写它来分离你的 特克斯特雷德 从 Location 类型-这样您就可以轻松地修改 位置 独立或甚至提供其他基于跟踪阅读进度的功能。

interface ITracker {
  void AdvanceString(string s);
}

class TrackingReader : TextReader {
  private TextReader source;
  private ITracker tracker;
  public TrackingReader(TextReader source, ITracker tracker) {
    this.source = source;
    this.tracker = tracker;
  }
  public override int Read(char[] buffer, int index, int count) {
    int res = base.Read(buffer, index, count);
    tracker.AdvanceString(buffer.Skip(index).Take(res);
    return res;
  }
}

我还将把跟踪器的创建封装到一些工厂方法中(这样您在处理构造的应用程序中就有一个单独的位置)。注意,您可以使用这个简单的设计来创建 特克斯特雷德 将进度报告给多个 位置 对象:

static TextReader CreateReader(TextReader source, params ITracker[] trackers) {
   return trackers.Aggregate(source, (reader, tracker) =>
       new TrackingReader(reader, tracker));
}

这就产生了一系列 跟踪阅读器 对象和每个对象都向作为参数传递的一个跟踪程序报告读取进度。

关于基于事件的 :我认为在.NET库中使用标准的.NET/C事件并不像在.NET库中那样频繁,但我认为这种方法可能也很有趣-特别是在C 3中,在C 3中,您可以使用诸如lambda表达式甚至反应式框架之类的功能。

简单使用不会增加太多锅炉板:

using(ReaderWithEvents reader = new ReaderWithEvents(source)) {
  reader.Advance += str => loc.AdvanceString(str);
  // ..
}

但是,您也可以使用 Reactive Extensions 处理事件。要计算源文本中的新行数,可以编写如下内容:

var res =
  (from e in Observable.FromEvent(reader, "Advance")
   select e.Count(ch => ch == '\n')).Scan(0, (sum, current) => sum + current);

这会给你一个活动 res 每次从 特克斯特雷德 事件携带的值将是当前行数(在文本中)。

我要去平原 TextReader 包装,因为这似乎是最自然的方法。另外,我不认为你提到的缺点是真正的缺点:

• 除了TextReader实例外,用户还需要创建和释放locatedExtreaderWrapper实例。

好吧,如果用户需要跟踪,他无论如何都需要操纵与跟踪相关的对象,并且创建一个包装器并不是什么大问题…为了使事情更简单,您可以创建一个扩展方法,该方法为 特克斯特雷德 .

• 不允许在没有包装层的情况下添加不同类型的跟踪或不同的位置跟踪。

您可以使用 Location 对象,而不是单个对象:

public class LocatedTextReaderWrapper : TextReader {

    private TextReader source;

    public IList<Location> Locations {
        get;
        private set;
    }

    public LocatedTextReaderWrapper(TextReader source, params Location[] locations) {
        this.Locations = new List<Location>(locations);
        this.source = source;
    }

    public override int Read(char[] buffer, int index, int count) {
        int ret = this.source.Read(buffer, index, count);

        if(ret >= 0) {
            var s = string.Concat(buffer.Skip(index).Take(count));
            foreach(Location loc in this.Locations)
            {
                loc.AdvanceString(s);
            }
        }

        return ret;
    }

    // etc.
}

afaik,如果您使用postsharp,它会将自己注入编译过程,并根据需要重写代码,这样您就没有任何永久的依赖关系(除了要求API用户使用postsharp编译源代码之外)。