Reactive.EventAggregator.Net35

Event Aggregator using Reactive Extensions 1.0, compatible with .NET 3.5 applications.

Inspired by https://github.com/shiftkey/Reactive.EventAggregator

Installation

To install it, just run this from the Package Manager Console or download from NuGet manually:

Install-Package Reactive.EventAggregator.Net35

Usage

Subscribing to an event

private class TestEvent
{
    public int Status { get; set; }
}

[Test]
public void Subscribe_WhenGivenEvent_ShouldRaiseEvent()
{
    var eventWasRaised = false;
    var eventBus = new EventAggregator();

    eventBus.GetEvent<TestEvent>().Subscribe(new Observer<TestEvent>(x => eventWasRaised = true));

    eventBus.Publish(new TestEvent());

    Assert.IsTrue(eventWasRaised);
}

Unsubscribing to an event

private class TestEvent
{
    public int Status { get; set; }
}

[Test]
public void Unsubscribe_WhenGivenEvent_ShouldNotRaiseEvent()
{
    var eventWasRaised = false;
    var eventBus = new EventAggregator();

    var subscription = eventBus.GetEvent<TestEvent>().Subscribe(new Observer<TestEvent>(x => eventWasRaised = true));

    subscription.Dispose();
    eventBus.Publish(new TestEvent());

    Assert.IsFalse(eventWasRaised);
}

Using the EventBus singleton

Normally, I'd recommend using a DI container to set up EventAggregator as a singleton instance for IEventAggregator, but there are some situations where this is not possible.
For those situations, there is a class called EventBus. It has the same methods as EventAggregator and can be used similarily:

public class ControlLoaded
{
    public ControlLoaded(Control control)
    {
        this.Control = control;
    }

    public Control Control { get; private set; }
}

public class MainForm : Form
{
    protected SubUserControl SubControl;

    public IList<Control> LoadedControls = new List<Control>();

    public MainForm()
    {
        EventBus.Instance.GetEvent<ControlLoaded>().Subscribe(new Observer<ControlLoaded>(x => this.LoadedControls.Add(x.Control)));

        this.SubControl = new SubUserControl();
    }
}

public class SubUserControl : UserControl
{
    public SubUserControl()
    {
        // Since we're in a test, trigger OnLoad manually
        this.OnLoad(EventArgs.Empty);
    }

    protected override void OnLoad(EventArgs e)
    {
        EventBus.Instance.Publish(new ControlLoaded(this));
    }
}

[Test]
public void Load_WhenUserControlLoaded_ParentFormShouldHaveProcessedEvent()
{
    var f = new MainForm();

    Assert.That(f.LoadedControls.All(x => x.GetType() == typeof(SubUserControl)));
}