public void TestExceptionInUpstream()
{
    bool thrown = false;
    SourceList<int> list = new SourceList<int>();
    list.Connect()
        .Do(_ =>
        {
            thrown = true;
            throw new InvalidOperationException("Test");
        })
        .OnItemRemoved(_ => {})
        .Subscribe();

    list.Add(1); // This should throw, but does not.

    Console.WriteLine($"thrown: {thrown}."); // We should never get here, but get this line in the console output.
}

public void ExpectedBehavior()
{
    bool thrown = false;

    SourceList<int> list = new SourceList<int>();
    list.Connect()
        .Do(_ =>
        {
            thrown = true;
            throw new InvalidOperationException("Test");
        })
        .OnItemAdded(_ => { })
        .Subscribe();

    list.Add(1); // This throws the exception.

    Console.WriteLine($"thrown: {thrown}."); // We never get here.
}