Kotlin wrapper for observing the Firebase Realtime Database with Live Data

FirebaseLiveData.kt

class FirebaseLiveData(
        private val reference: DatabaseReference
) : LiveData<DataSnapshot>() {

    private var eventListener: ValueEventListener? = null

    override fun onActive() {
        super.onActive()
        logd("onActive $reference")
        eventListener = reference.addValueEventListener(FValueEventListener(
                onDataChange = { data ->
                    value = data
                },
                onError = { error ->
                    loge("FirebaseLiveData error", error.toException())
                }
        ))
    }

    override fun onInactive() {
        super.onInactive()
        logd("onInactive $reference")
        eventListener?.let {
            reference.removeEventListener(it)
            eventListener = null
        }
    }
}

class FValueEventListener(val onDataChange: (DataSnapshot) -> Unit, val onError: (DatabaseError) -> Unit) : ValueEventListener {
    override fun onDataChange(data: DataSnapshot) = onDataChange.invoke(data)
    override fun onCancelled(error: DatabaseError) = onError.invoke(error)
}