我希望有一个对我的应用程序可用的记录器。我的应用程序记录了有趣的事情,订阅者订阅了这些消息。例如,订户可能将消息放入数据库,Windows事件日志或消息总线等中。
下面是我所写内容的简化复制:
using System;
using System.Reactive.Subjects;
namespace ConsoleApplication17
{
internal interface ILogger
{
void Log(String message);
}
internal class Logger : ILogger
{
private readonly Subject<String> _logMessagesObservable = new Subject<string>();
public void Log(string json)
{
_logMessagesObservable.OnNext(json);
}
public IObservable<String> LogMessagesObservable { get { return _logMessagesObservable; } }
}
internal class ConsoleLogListener
{
public ConsoleLogListener(IObservable<String> messages)
{
messages.Subscribe(Console.WriteLine);
}
}
internal class WindowsEventListener
{
public WindowsEventListener(IObservable<String> messages)
{
messages.Subscribe(WriteToEventLog);
}
private void WriteToEventLog(String message)
{
//Write to event log
}
}
class Program
{
static void Main(string[] args)
{
Logger logger = new Logger();
//Link up any subscribers
new ConsoleLogListener(logger.LogMessagesObservable);
new WindowsEventListener(logger.LogMessagesObservable);
//... more listeners go here.
DoSomeWork(logger);
}
private static void DoSomeWork(ILogger logger)
{
logger.Log("Something interesting");
logger.Log("Something else interesting");
}
}
}
但是我对看起来像这样的代码不满意:
//Link up any subscribers
new ConsoleLogListener(logger.LogMessagesObservable);
new WindowsEventListener(logger.LogMessagesObservable);
//... more listeners go here.
由于某种原因,这使我感到烦恼,但我无法将手指放在上面。我猜想像这样新建一个监听器而不保留引用就显得很奇怪。
我要做什么有更好/更被接受的模式?
我可能希望监听器实现IObserver<string>
,然后将两个连接起来,如下所示:
logger.LogMessagesObservable.Subscribe(new ConsoleLogListener());
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句