UniRx

UniRx의 선언적 프로그래밍 기법은 높은 가독성을 보장해 주지만 복잡한 처리를 수행하기에는 기존 절차적 방식의 프로그래밍에 비해 불리하다. 내부적으로 적은 크기라 해도 동적 생성으로 인한 가비지가 쌓이는 문제가 있기 때문이다. 오퍼레이터들로 처리하기에 복잡한 코드들은 무리해서 UniRx로 구현하기보다는 절차적 프로그래밍을 활용할 수 있도록 코루틴(Coroutine)을 사용하고 여기에 스트림을 적절히 연동함으로써 UniRx의 진가를 100% 발휘할 수 있다. ※ 코루틴(Coroutine)에서 IObservable로 변환 코루틴(Coroutine)을 스트림으로 변환 → 코루틴에서 처리 완료된 작업의 결과를 UniRx의 오퍼레이터에서 이어받아 사용할 수 있게 해줌 복잡한 처리나 상태에 의존한 처리, 로직 중..

※ 팩토리 메서드 팩토리 메서드는 Observable 클래스에 팩토리 메서드 디자인 패턴 형태로 구현된 static 메서드 들이다. 주로 Observable 스트림의 값을 발행하고 컨트롤 하는 오퍼레이터들이다. Operator 기능 비고 Observable.Create 직접 Observable 객체를 생성한다. Observable.Return 1개의 메세지만 전달한다. Observable.Repeat 메세지의 전달을 반복한다. Observable.Range 지정된 수치의 메세지를 전달한다. Observable.Timer / Observable.Interval 일정 간격을 두고 메세지를 전달한다. Timer 는 실행 후 몇 초 이후 발생 Interval 은 실행 후 몇 초 마다 발생 Observable.E..

오퍼레이터(Operator)? UniRx에서 Observable을 통해 관찰 대상이 결정되면 스트림에 값들을 흘려보내게 된다. 이 값들은 상황과 필요에 따라 기본값이 아닌 조작이나 필터링 등을 거쳐서 실제 내가 필요한 값들로 바꿔야 구독자에서 바로 사용할 수 있는 경우가 대부분일 것이다. 이 일련의 상황을 간단하게 그림으로 표현해 보면 아래와 같다. 이런 상황에서 데이터를 조작하게 해주는 명령어를 Operator라고 한다. UniRx에서는 수십 가지에 달하는 정말 다양한 오퍼레이터를 제공한다. 그중에서도 상황에 맞는 오퍼레이터를 얼마나 잘 선택하느냐가 UniRx 활용 능력의 핵심이기도 하다. 이 포스팅에선 대표적인 오퍼레이터인 Where와 Select의 사용법을 살펴본다. LINQ 에도 동일한 오퍼레이터..

Dispose public interface IObservable { IDisposable Subscribe(IObserver observer); } Subscribe의 반환값인 IDisposable 은 가비지컬렉터가 관리하지 않는 리소스를 해제해 주기 위한 C#의 기본 인터페이스 IDisposable.Dispose()로 해제 var subject = new Subject(); // IDispose를 저장 var disposable = subject.Subscribe(x => Debug.Log(x), () => Debug.Log("OnCompleted")); //Subscribe(OnNext, OnCompleted) 오버로드 subject.OnNext(1); subject.OnNext(2); // Sub..

UniRx에서 사용되는 이벤트 메시지는 이 3가지를 이용해 처리된다. OnNext : 일반적인 이벤트 발생 시 통지 OnError : 스트림 처리 중 예외(Exception) 발생 시 통지 OnComplete : 스트림 종료 통지 IObserver와 IObservable 인터페이스 클래스 소스 코드를 보면 위 도표와 똑같이 각각 3개, 1개의 메서드만 정의되어 있다. using System; namespace UniRx { public interface IObserver { void OnNext(T value); void OnError(Exception error); void OnCompleted(); } } Subscribe 메서드는 이 메시지들 중 원하는 것만 받아서 처리할 수 있게 각 상황별로 오버..

Subject 원하는 자료형을 Subject 타입의 인스턴스로 생성하면 UniRx의 스트림을 사용할 수 있다. // Subject 타입의 string 객체 생성 Subject strSubject = new(); // strSubject 호출 시 출력 strSubject.Subscribe(msg => Debug.Log($"Subscribe : {msg}")); // 이벤트 메세지 전달 strSubject.OnNext("Hello"); // Result Subcribe : Hello 위에서 Subscribe 와 OnNext 를 Subject 의 메소드로 설명했는데 사실은 Subject 의 메소드가 아니라 Subject 가 구현한 IObserver 인터페이스와 IObservable 인터페이스 의 메소드 들을 ..

제작자 : @neuecc (Yoshifumi Kawai, CTO at Grani, Microsoft C# MVP) License : MIT 다운로드 : AssetStore, GitHub UniRx - Reactive Extensions for Unity Functional Reactive Programming(FRP)를 C#에 사용할 수 있게 만든 .Net Reactive Extensions를 일본인 @neuecc가 Unity 전용으로 최적화하여 공개한 라이브러리 그런 만큼 더 가벼우며 UGUI, GameObject, Coroutine 등 유니티의 시스템과 매우 강력하고 직관적으로 연동이 되어 있어 쉽게 Reactive Programming 의 사용이 가능 일련의 흐름을 관찰할 수 있는 (Observab..