CombineLatest 테스트 케이스

CombineLatestTest.cs

using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using Microsoft.VisualStudio.TestTools.UnitTesting;

namespace RxUnitTest
{
    [TestClass]
    public class CombineLatestTest
    {
        [TestMethod]
        public void CombineLatest_works_correctly()
        {
            // Arrange
            var streamA = new BehaviorSubject<int>(3);
            var streamB = new Subject<int>();

            IObservable<int> combined = streamA.CombineLatest(streamB, (a, b) => a + b);

            // Act
            int actual = default(int);
            combined.Subscribe(x => actual = x);
            streamB.OnNext(4);

            // Assert
            Assert.AreEqual(7, actual);
        }
    }
}