5

我有 3 个 TextReader——StreamReaders 和 StringReaders 的组合。从概念上讲,它们的连接是一个单一的文本文档。

我想调用一个采用单个 TextReader 的方法(不在我的控制之下)。是否有任何内置或简单的方法可以从多个 TextReader 连接 TextReader?

(我可以编写自己的 TextReader 子类,但看起来工作量很大。在这种情况下,我只需将它们全部写入一个临时文件,然后使用单个 StreamReader 打开它。)

我缺少一个简单的解决方案吗?

4

1 回答 1

6

我只是把它放在一起,所以它不是超级健壮(没有错误处理等),但基本的测试用例是有效的。

它通过为TextReader's 创建一个扩展方法来工作,这需要一秒钟,并返回一个新的 TextReader 类,该类在第一个内部调用Read()直到它用完,然后开始调用Read()第二个。您可以无限期地链接它。

要提供完整的实现,您TextReader只需要实现Read()Peek()和. 所有其他方法都依赖于特定的实现来工作。所以创建你自己的真的不是那么糟糕,你可以在下面看到。Close()Dispose()Read()TextReader

这也减轻了任何性能问题,因为我们只是包装现有的 TextReader 而不是实际调用它们来执行连接。

class Program
{
    static void Main(string[] args)
    {
        StringReader first = new StringReader("hello ");
        StringReader second = new StringReader("world");
        StringReader third = new StringReader("!");

        using (var allOfThem = first.Concat(second).Concat(third))
        {
            //writes "hello world!"
            Console.WriteLine(allOfThem.ReadToEnd());
        }
        Console.Read();
    }
}

public static class Extensions
{
    public static TextReader Concat(this TextReader first, TextReader second)
    {
        return new ChainedTextReader(first, second);
    }

    private class ChainedTextReader : TextReader
    {
        private TextReader first;
        private TextReader second;
        private bool readFirst = true;

        public ChainedTextReader(TextReader first, TextReader second)
        {
            this.first = first;
            this.second = second;
        }

        public override int Peek()
        {
            if (readFirst)
            {
                return first.Peek();
            }
            else
            {
                return second.Peek();
            }
        }

        public override int Read()
        {
            if (readFirst)
            {
                int value = first.Read();
                if (value == -1)
                {
                    readFirst = false;
                }
                else
                {
                    return value;
                }
            }
            return second.Read();
        }

        public override void Close()
        {
            first.Close();
            second.Close();
        }

        protected override void Dispose(bool disposing)
        {
            base.Dispose(disposing);
            if (disposing)
            {
                first.Dispose();
                second.Dispose();
            }
        }
    }
}
于 2010-05-27T23:25:42.610 回答