在Windows服务中使用Rx

Question

我试图在Windows服务中使用Rx扩展,但我被卡住了.我找到的样本不起作用.我将用一些代码解释我想要实现的目标.我正在创建的第一个类实际上是完成所有工作的类:

class Worker : IDisposable {
    public Worker() {
    }

    private void Run() {
    }

    public void Dispose() {
    }
}

我想在OnStart中创建一个实例并将其杀死OnStop:

public partial class MyService : ServiceBase {
    private Worker _Worker;

    public MyService () {
        InitializeComponent ();
    }

    protected override void OnStart ( string[] args ) {
        _Worker = new Worker();
    }

    protected override void OnStop () {
        _Worker.Dispose();
        _Worker = null;
    }
}

所以我在Worker的构造函数中执行此操作:

/* _TimesEvents and _Events are class level variables */
_TimedEvents = Observable.Timer ( TimeSpan.FromSeconds ( 1 ), new EventLoopScheduler() ).Timestamp ();
_Events = ( from events in _TimedEvents select events ).Subscribe ( e => Run() );

在Dispose中,我只是处理_Events.运行一次调用.我怀疑它每秒都会被调用或根本不调用.

我错过了什么？

编辑:

为了测试我的Main()样子:

static void Main ( ) {
    var args = Environment.GetCommandLineArgs ();
    if ( null != args && args.Length > 0 ) {
        using ( BRWorker worker = new BRWorker ()  ) {
            System.Windows.Forms.MessageBox.Show ( "Press ok to quit", "Test", System.Windows.Forms.MessageBoxButtons.OK );
        }
    } else {
        ServiceBase[] ServicesToRun;
        ServicesToRun = new ServiceBase[] 
        { 
            new BRService() 
        };
        ServiceBase.Run ( ServicesToRun );
    }
}

Answer 1

Observable.Timer产生一个单值的后TimeSpan完成.你想使用Observable.Interval它在每个 之后产生一个新值TimeSpan.