订阅 IObservable<T> 不是类型委托

Question

我继承了一个开发人员的代码，我想将它转换为 c#，因为开发人员用 C# 制作了他的库。但是，我拥有的唯一一个向我展示如何订阅此服务的示例是在 vba 中，我不知道它是如何附加到它的。

namespace exampleExcelAddin.Common.Services
{
    public class LogEntry
    {
        public Type Type;
        public string Message;
        public IDictionary<string, object> Meta = new Dictionary<string, object>();
    }

    public interface ILogger
    {
        void LogMessage(string message);

        void LogMessage(Exception exception);
    }

    public static class Logger
    {
        readonly static Lazy<ISubject<LogEntry>> _outputStream = new Lazy<ISubject<LogEntry>>(() => {
            return new ReplaySubject<LogEntry>();
        });

        public static ILogger Create(Type loggerType) => new TypedLogger(loggerType, _outputStream.Value);

        public static IObservable<LogEntry> Output => _outputStream.Value;

        class TypedLogger : ILogger
        {
            readonly ISubject<LogEntry> outputStream;
            readonly Type loggerType;

            internal TypedLogger(Type loggerType, ISubject<LogEntry> outputStream)
            {
                this.loggerType = loggerType;
                this.outputStream = outputStream;
            }

            public void LogMessage(string message)
            {
                outputStream.OnNext(new LogEntry {
                    Type = loggerType,
                    Message = message
                });
            }

            public void LogMessage(Exception exception)
            {
                var logEntry = new LogEntry {
                    Type = loggerType,
                    Message = $"Exception: {exception.Message}"
                };

                logEntry.Meta.Add("StackTrace", exception.StackTrace);

                outputStream.OnNext(logEntry);
            }
        }
    }
}

vb.net 中的工作示例是这样的......

 Private Shared log As ILogger = Logger.Create(GetType(myRibbon))
 Logger.Output.Subscribe(
            Sub(entry)
                If MySettings.Default.EnableLogging Then

                    Dim logBuilder As New StringBuilder()
                    logBuilder.
                        AppendLine("-------------------------------------------------").
                        AppendLine($"Type: {entry.Type}").
                        AppendLine($"Message: {entry.Message}")

                    For Each meta In entry.Meta
                        logBuilder.
                            AppendLine($"Meta-Key: {meta.Key}").
                            AppendLine($"Meta-Value: {meta.Value}")
                    Next

                    logBuilder.
                        AppendLine("-------------------------------------------------" & Environment.NewLine)

                    IO.File.AppendAllText(logPath, logBuilder.ToString())
                End If
            End Sub)

在转换它时得到了一些帮助，并且我的 lambda 表达式不断出现问题，因为它不是我理解的委托类型，但一直碰壁。关于如何使用这些服务的内容。

Logger.Output.Subscribe(entry => {
                if (Settings.Default.EnableLogging) {
                    var logBuilder = new StringBuilder();
                    logBuilder.AppendLine("-------------------------------------------------").AppendLine($"Type: {entry.Type}").AppendLine($"Message: {entry.Message}");
                    foreach (var meta in entry.Meta) { logBuilder.AppendLine($"Meta-Key: {meta.Key}").AppendLine($"Meta-Value: {meta.Value}"); }
                    _ = logBuilder.AppendLine("-------------------------------------------------" + Environment.NewLine); System.IO.File.AppendAllText(logPath, logBuilder.ToString());
                    }
            });

Answer 1

想通了，只需要一个库使用的包。

Install-Package System.Reactive -Version 5.0.0