RxSwift distinct operator

이전에 발생한 이벤트와 다른 이벤트가 발생할 경우에 나머지 흐름을 처리하도록 하는 operator 입니다.

distinctUntilChanged() 혹은 distinctUntilChanged(_ comparer: @escaping (Self.E, Self.E) throws -> Bool) 등등 다양한 조건을 사용할 수 있도록 되어 있습니다.

아래와 같은 부분은 아주 간단하게 사용할수 있으며, Equtable을 구현하여 두었기 때문에 아주 편하게 동작을 하게 됩니다.

Observable.of("A", "A", "B", "C")
    .distinctUntilChanged()

* 출력은 A, B, C로 나오게 됩니다.

그럼 위에 말한 distanctUntilChanged는 어떻게 사용을 하면 되는가에 대해서 설명 드리겠습니다.

일단 Equtable을 구현한 Class, Struct로 사용을 하면 이것은 문제가 안됩니다.

그러나 이것을 사용하지 않고 closure로 바로 사용을 하겠다면, 다음과 같이 사용을 합니다.

Observable.of("A", "A", "B", "C")
    .distinctUntilChanged { before, after -> Bool in
            before == after
    }
    .subscribe(onNext: { str in
        print("str = \(str)")
    }).disposed(by: disposeBag)

이렇게 하면 출력 결과는 다음과 같습니다.

str = A
str = B
str = C

결론적으로 말을 한다면 true의 값이 넘어오게 되면 비교하는것이 같다라고 판단하는것입니다.

그럼 즐코딩