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

Question

我正在编写一个小型记录器，我想打开日志文件一次，在日志消息到达时保持反应性写入，并在程序终止时处理所有内容。

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

我想更新我以前的解决方案的设计，在该解决方案中，我有一个 ConcurrentQueue 作为缓冲区，并且 using 语句中有一个循环消耗了队列。

具体来说，我想同时利用using语句构造，这样我就不必显式关闭流和写入器，以及反应式，无环编程风格。目前我只知道如何一次使用这些构造之一：using/loop 组合，或 explicit-stream-close/reactive 组合。

这是我的代码：

    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?
            }
        }
    }

Answer 1

您需要使用 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)));

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

Write to open FileStream using reactive programming

c#

filestream

system.reactive

tpl-dataflow