MediatorLiveData 사용

Mediator LiveDarta의 역할은 말 그대로 중간자의 역할로 다른 LiveData를 감청할 수 있다. 예를 들어 ExitText에 텍스트를 입력하는 동시에 텍스트 개수를 표시하기를 원하는 수요가 있다.

class MainViewModel : ViewModel() {
    val message: MutableLiveData<String> = MutableLiveData()
    val count: MediatorLiveData<Int> = MediatorLiveData()

    init {
        count.value = 0

        count.addSource(message) {
            val cnt = message.value?.length ?: 0
            count.postValue(cnt)
        }
    }

    fun postMessage(message: String) {
        this.message.postValue(message)
    }
}

EditText의 리셋에서 postMessage를 통해 메시지를 업데이트하고,count를 통해 addSource를 통해 메시지의 변화를 감청한 후 자신을 업데이트합니다.
addSource
If the given LiveData is already added as a source but with a different Observer, IllegalArgumentException will be thrown.
addSource는 감시된 Livedata가 중복 구독되지 않도록 보장합니다. 만약에 우리가 수동으로 observe를 한다면 중복 구독으로 인해 데이터가 이상하게 받아들일 수 있습니다.addsrouce의 원본 코드를 통해 이 점을 알 수 있습니다

public <S> void addSource(@NonNull LiveData<S> source, @NonNull Observer<S> onChanged) {
        Source<S> e = new Source<>(source, onChanged);
        Source<?> existing = mSources.putIfAbsent(source, e);
        if (existing != null && existing.mObserver != onChanged) {
            throw new IllegalArgumentException(
                    "This source was already added with the different observer");
        }
        if (existing != null) {
            return;
        }
        if (hasActiveObservers()) {
            e.plug();
        }
    }

postValue 사용 주의
위의 예에서 우리가 코드를 수정해서 실현하면 정상적으로 운행할 수 있습니까?

class MainViewModel : ViewModel() {
    val message: MutableLiveData<String> = MutableLiveData()
    val count: MutableLiveData<Int> = MutableLiveData()

    fun postMessage(message: String) {
        this.message.postValue(message)
        updateCount()
    }

    private fun updateCount() {
        val cnt = message.value?.length ?: 0
        count.postValue(cnt)
    }
}

테스트를 통해count와 메시지 업데이트가 동기화되지 않는 것을 발견했습니다.postValue는 비동기적인 작업이기 때문에 postValue를 통해 메시지를 업데이트한 후 updateCount에서 메시지의 최신value를 동기화하면 업데이트되지 않은 값을 얻을 수 있고 버그가 발생할 수 있습니다.
최후
간단한 코드에서는 이런 버그가 쉽게 감지되지만 복잡한 프로젝트에서는 이런 시퀀스 문제가 코드를 쓸 때 무시될 수 있기 때문에 LiveData를 사용할 때 MediatorLiveData와 같은 도구를 많이 활용하여 두 줄의 코드를 더 써도 시퀀스의 정확성을 확보해야 한다.