Use CallbackList for collecting STDOUT in flash screen

Fix #2988

app/src/main/java/com/topjohnwu/magisk/ktx/XJava.kt

@@ -1,6 +1,7 @@
 package com.topjohnwu.magisk.ktx
 
 import android.os.Build
+import androidx.collection.SparseArrayCompat
 import timber.log.Timber
 import java.io.File
 import java.io.InputStream
@@ -11,7 +12,6 @@ import java.text.SimpleDateFormat
 import java.util.*
 import java.util.zip.ZipEntry
 import java.util.zip.ZipInputStream
-import kotlin.NoSuchElementException
 
 fun ZipInputStream.forEach(callback: (ZipEntry) -> Unit) {
     var entry: ZipEntry? = nextEntry
@@ -36,13 +36,19 @@ inline fun <In : InputStream, Out : OutputStream> withStreams(
     }
 }
 
-inline fun <T, R> List<T>.firstMap(mapper: (T) -> R?): R {
-    for (item: T in this) {
-        return mapper(item) ?: continue
-    }
-    throw NoSuchElementException("Collection contains no element matching the predicate.")
+fun <T> MutableList<T>.update(newList: List<T>) {
+    clear()
+    addAll(newList)
 }
 
+operator fun <E> SparseArrayCompat<E>.set(key: Int, value: E) {
+    put(key, value)
+}
+
+fun <T> MutableList<T>.synchronized() = Collections.synchronizedList(this)
+fun <T> MutableSet<T>.synchronized() = Collections.synchronizedSet(this)
+fun <K, V> MutableMap<K, V>.synchronized() = Collections.synchronizedMap(this)
+
 fun String.langTagToLocale(): Locale {
     if (Build.VERSION.SDK_INT >= 21) {
         return Locale.forLanguageTag(this)

app/src/main/java/com/topjohnwu/magisk/ktx/XList.kt

@@ -1,87 +0,0 @@
-package com.topjohnwu.magisk.ktx
-
-import androidx.collection.SparseArrayCompat
-import androidx.databinding.ObservableList
-import com.topjohnwu.magisk.utils.DiffObservableList
-import kotlinx.coroutines.*
-
-fun <T> MutableList<T>.update(newList: List<T>) {
-    clear()
-    addAll(newList)
-}
-
-fun List<String>.toShellCmd(): String {
-    val sb = StringBuilder()
-    for (s in this) {
-        if (s.contains(" ")) {
-            sb.append('"').append(s).append('"')
-        } else {
-            sb.append(s)
-        }
-        sb.append(' ')
-    }
-    sb.deleteCharAt(sb.length - 1)
-    return sb.toString()
-}
-
-fun <T1, T2> ObservableList<T1>.sendUpdatesTo(
-    target: DiffObservableList<T2>,
-    scope: CoroutineScope,
-    mapper: (List<T1>) -> List<T2>
-) = addOnListChangedCallback(object :
-    ObservableList.OnListChangedCallback<ObservableList<T1>>() {
-    override fun onChanged(sender: ObservableList<T1>?) {
-        updateAsync(sender ?: return)
-    }
-
-    override fun onItemRangeRemoved(sender: ObservableList<T1>?, p0: Int, p1: Int) {
-        updateAsync(sender ?: return)
-    }
-
-    override fun onItemRangeMoved(sender: ObservableList<T1>?, p0: Int, p1: Int, p2: Int) {
-        updateAsync(sender ?: return)
-    }
-
-    override fun onItemRangeInserted(sender: ObservableList<T1>?, p0: Int, p1: Int) {
-        updateAsync(sender ?: return)
-    }
-
-    override fun onItemRangeChanged(sender: ObservableList<T1>?, p0: Int, p1: Int) {
-        updateAsync(sender ?: return)
-    }
-
-    private var updater: Job? = null
-
-    private fun updateAsync(sender: List<T1>) {
-        updater?.cancel()
-        updater = scope.launch {
-            val (list, diff) = withContext(Dispatchers.Default) {
-                val list = mapper(sender)
-                list to target.calculateDiff(list)
-            }
-            target.update(list, diff)
-        }
-    }
-})
-
-fun <T1> ObservableList<T1>.copyNewInputInto(
-    target: MutableList<T1>
-) = addOnListChangedCallback(object : ObservableList.OnListChangedCallback<ObservableList<T1>>() {
-    override fun onChanged(p0: ObservableList<T1>?) = Unit
-    override fun onItemRangeRemoved(p0: ObservableList<T1>?, p1: Int, p2: Int) = Unit
-    override fun onItemRangeMoved(p0: ObservableList<T1>?, p1: Int, p2: Int, p3: Int) = Unit
-    override fun onItemRangeChanged(p0: ObservableList<T1>?, p1: Int, p2: Int) = Unit
-    override fun onItemRangeInserted(
-        sender: ObservableList<T1>?,
-        positionStart: Int,
-        itemCount: Int
-    ) {
-        val positionEnd = positionStart + itemCount
-        val addedValues = sender?.slice(positionStart until positionEnd).orEmpty()
-        target.addAll(addedValues)
-    }
-})
-
-operator fun <E> SparseArrayCompat<E>.set(key: Int, value: E) {
-    put(key, value)
-}