R3/tests/R3.Tests/OperatorTests/SwitchTest.cs

namespace R3.Tests.OperatorTests;

public class SwitchTest
{
    [Fact]
    public void Switch()
    {
        var sources = new Subject<Observable<int>>();

        using var list = sources.Switch().ToLiveList();

        var source1 = new Subject<int>();
        var source2 = new Subject<int>();

        sources.OnNext(source1);

        list.AssertEmpty();

        source1.OnNext(1);
        source1.OnNext(2);

        sources.OnNext(source2);

        source2.OnNext(10);

        source1.OnNext(3);

        list.AssertEqual([1, 2, 10]);

        source1.OnCompleted();
        source2.OnCompleted();

        list.AssertIsNotCompleted();

        sources.OnCompleted();

        list.AssertIsCompleted();
    }
}