c# – 使用反应式编程写入打开FileStream

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c# – 使用反应式编程写入打开FileStream，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1348字，纯文字阅读大概需要2分钟。

内容图文

我正在编写一个小的记录器,我想打开一次日志文件,在日志消息到达时继续写入,并在程序终止时处理所有内容.

我不确定如何保持FileStream打开并在消息到达时反应性地写入消息.

我想从我之前的解决方案更新设计,其中我有一个ConcurrentQueue充当缓冲区,并且在使用队列的using语句中有一个循环.

具体来说,我想同时利用using语句构造,因此我不必显式关闭流和编写器,以及反应式无循环编程风格.目前我只知道如何同时使用这些结构之一：使用/循环组合,或显式流关闭/反应组合.

这是我的代码：

    BufferBlock<LogEntry> _buffer = new BufferBlock<LogEntry>();


    // CONSTRUCTOR
    public DefaultLogger(string folder)
    {
        var filePath = Path.Combine(folder, $"{DateTime.Now.ToString("yyyy.MM.dd")}.log");

        _cancellation = new CancellationTokenSource();

        var observable = _buffer.AsObservable();

        using (var stream = File.Create(_filePath))
        using (var writer = new StreamWriter(stream))
        using (var subscription = observable.Subscribe(entry =>
                                    writer.Write(GetFormattedString(entry))))
        {
            while (!_cancellation.IsCancellationRequested)
            {
                // what do I do here?
            }
        }
    }

解决方法:

你需要使用Observable.Using.它旨在创建一个IDisposble资源,在序列结束时处理它.

尝试这样的事情：

IDisposable subscription = 
    Observable.Using(() => File.Create(_filePath),
        stream => Observable.Using(() => new StreamWriter(stream),
            writer => _buffer.AsObservable().Select(entry => new { entry, writer })))
        .Subscribe(x => x.writer.Write(GetFormattedString(x.entry)));

内容总结

以上是互联网集市为您收集整理的c# – 使用反应式编程写入打开FileStream全部内容，希望文章能够帮你解决c# – 使用反应式编程写入打开FileStream所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端