REACT Archives - icodebroker

[C#/COMMON/REACT/.NET5] ObservableExtensions 클래스 : Subscribe 확장 메소드에서 예외 처리하기

■ ObservableExtensions 클래스의 Subscribe 확장 메소드에서 예외를 처리하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Reactive.Linq;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            IObservable<DateTimeOffset> observable = Observable.Interval(TimeSpan.FromSeconds(1))
                                                         .Timestamp()
                                                         .Where(x => x.Value % 2 == 0)
                                                         .Select(x => x.Timestamp);

            observable.Subscribe
            (
                x => Console.WriteLine(x),
                ex => Console.WriteLine(ex)
            );

            Console.ReadKey(false);
        }

        #endregion
    }
}

using System;

using System.Reactive.Linq;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

IObservable<DateTimeOffset> observable = Observable.Interval(TimeSpan.FromSeconds(1))

.Timestamp()

.Where(x => x.Value % 2 == 0)

.Select(x => x.Timestamp);

observable.Subscribe

(

x => Console.WriteLine(x),

ex => Console.WriteLine(ex)

);

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/REACT/.NET5] IObservable 인터페이스 사용하기

■ IObservable<T> 인터페이스를 사용하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Reactive.Linq;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            IObservable<DateTimeOffset> observable = Observable.Interval(TimeSpan.FromSeconds(1))
                                                         .Timestamp()
                                                         .Where(x => x.Value % 2 == 0)
                                                         .Select(x => x.Timestamp);

            observable.Subscribe(x => Console.WriteLine(x));

            Console.ReadKey(false);
        }

        #endregion
    }
}

using System;

using System.Reactive.Linq;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

IObservable<DateTimeOffset> observable = Observable.Interval(TimeSpan.FromSeconds(1))

.Timestamp()

.Where(x => x.Value % 2 == 0)

.Select(x => x.Timestamp);

observable.Subscribe(x => Console.WriteLine(x));

Console.ReadKey(false);

}

#endregion

}

TestProject.zip