[Android] MediatorLiveData와 Transformations

💡 MediatorLiveData

다른 LiveData 객체를 observe하고 해당 객체의 OnChanged 이벤트를 받는 LiveData 하위 클래스이다.

addSource() 메서드를 통해 observe할 LiveData와 수행할 로직을 전달하여 추가하고, removeSource() 메서드를 통해 제거한다.

MediatorLiveData의 활성/비활성 상태를 onActive(), onInactive() 메서드를 통해 추가한 하위 LiveData 객체에 전달한다.

정리해보면 MediatorLiveData에 하나 또는 여러 개의 LiveData를 추가하여 추가된 LiveData의 onChanged 콜백을 받아 처리할 수 있다. 코드를 통해 살펴보자.

MediatorLiveData.java

MediatorLiveData는 MutableLiveData를 상속하고 있어 값 변경이 가능하다. 또한 LiveData와 Source를 저장할 Map을 가지고 있다.

Source

Source에는 LiveData와 onChanged 추상 메서드가 포함된 Observer 인터페이스를 가지고 있으며 Observer를 implements 하고 있다.

전달받은 LiveData의 onChanged() 콜백 등록을 위한 plug(), unplug() 메서드를 가지고 있고 onChanged() 콜백을 받으면 mObserver.onChanged(v);를 호출한다.

여기서 Source는 LiveData를 옵져빙하며 변화를 감지했을 때 전달받은 Observer의 onChanged를 호출한다는 것을 알 수 있었다.

addSource()

Source 객체를 전달받은 LiveData와 Observer를 이용해 생성해 주고 mSources에 저장한 뒤 MediatorLiveData가 액티브 상태일 경우 생성한 Source를 plug() 상태로 변경해 준다.

removeSource()

전달받은 LiveData를 mSources에서 제거하고 해당 Source가 null이 아닐 경우 unplug() 상태로 변경한다.

onActive(), onInactive()

Activity 및 Fragment의 Lifecycle 상태에 따라 onActive(), onInactive()가 호출되며, mSources에 있는 모든 Source를 plug(), unplug() 상태로 변경한다.

MediatorLiveData Example

EditText의 입력값을 받는 Two-way-binding을 사용한 MutableLiveData 두 가지가 있고 MediatorLiveData 하나와 그 Backing field인 LiveData가 하나 있다.

init 블록을 살펴보면 addSource 메서드를 이용해 두 가지 MutableLiveData와 콜백 시 수행할 코드를 설정한다.

userId, userPassword가 변경될 때 checkProcess() 메서드가 호출되며 _isProcessComplete의 상태가 변경될 것이다.

💡 Transformations

LiveData를 변환하고자 할 때 사용된다.

Transformations에 포함된 메서드를 사용하여 observer의 lifecycle에 걸쳐 정보를 전달할 수 있다.

Observer가 반환된 LiveData 객체를 옵저빙하지 않는 한 계산되지 않는다. 그 이유는 Transformations이 lazy 하게 계산되기 때문에 명시적 호출이나 종속성을 요구하지 않고 lifecycle 관련 동작이 암시적으로 전달됩니다.

Transformations.map() - 일대일 정적 변환

앞서 알아본 MediatorLiveData를 활용하고 있다.

새로운 MediatorLiveData 객체를 생성해 전달받은 LiveData와 mapFunction을 더해주며 반환한다. onChanged()에서 mapFunction의 결과를 MediatorLiveData 객체에 set 한다. 전달받은 LiveData의 값이 변경되면 반환된 MediatorLiveData 객체에 set 작업이 수행될 것이다.

mapFunction은 메인 스레드에서 실행된다.

Transformations.map() Example

userLiveData를 옵져빙 하고 있으며 값 변경이 일어났을 때 함수의 결과를 설정해 준다.

Transformations.switchMap() - 일대일 동적 변환

onChanged()를 살펴보면 함수의 결과로 받은 LiveData와 mSource를 비교하여 동일하면 아무 작업도 수행하지 않는다. 다를 경우 기존 Source는 제거하며 결과로 받은 LiveData를 map()과 동일한 방식으로 추가해 준다.

switchMapFunction은 메인 스레드에서 실행된다.

Transformations.switchMap() Example

setUserId() 메서드가 호출될 때 repository.getUserById(it) 함수가 호출되며 기존 LiveData와 동일한지 비교한다. 다를 경우 해당 결과가 적용된다.