feat: Add small utility extension functions (#8)

README.md

@@ -1,11 +1,11 @@
-The extensions library used in Tachiyomi.
+The extensions library used in Aniyomi.
 
 ```
 ext {
-    libVersion = '13'
+    libVersion = '14'
 }
 
 dependencies {
-    compileOnly "com.github.tachiyomiorg:extensions-lib:$libVersion"
+    compileOnly "com.github.aniyomiorg:extensions-lib:$libVersion"
 }
 ```

library/build.gradle

@@ -25,11 +25,15 @@ android {
 }
 
 dependencies {
-    implementation "com.squareup.okhttp3:okhttp:5.0.0-alpha.11"
-    implementation "io.reactivex:rxjava:1.3.8"
-    implementation "io.reactivex:rxandroid:1.2.1"
-    implementation "org.jsoup:jsoup:1.15.3"
-    implementation "com.github.inorichi.injekt:injekt-core:65b0440"
+    compileOnly("com.squareup.okhttp3:okhttp:5.0.0-alpha.11")
+    compileOnly("io.reactivex:rxjava:1.3.8")
+    compileOnly("io.reactivex:rxandroid:1.2.1")
+    compileOnly("org.jsoup:jsoup:1.15.3")
+    compileOnly("com.github.inorichi.injekt:injekt-core:65b0440")
+    compileOnly("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1")
+    def json = "1.5.1"
+    compileOnly("org.jetbrains.kotlinx:kotlinx-serialization-json:$json")
+    compileOnly("org.jetbrains.kotlinx:kotlinx-serialization-json-okio:$json")
 }
 
 task androidSourcesJar(type: Jar) {

library/src/main/java/eu/kanade/tachiyomi/util/CoroutinesExtensions.kt

@@ -0,0 +1,36 @@
+package eu.kanade.tachiyomi.util
+
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.runBlocking
+
+inline fun <A, B> Iterable<A>.parallelMap(crossinline f: suspend (A) -> B): List<B> =
+    runBlocking {
+        map { async(Dispatchers.Default) { f(it) } }.awaitAll()
+    }
+
+inline fun <A, B> Iterable<A>.parallelMapNotNull(crossinline f: suspend (A) -> B?): List<B> =
+    runBlocking {
+        map { async(Dispatchers.Default) { f(it) } }.awaitAll().filterNotNull()
+    }
+
+inline fun <A, B> Iterable<A>.parallelMapIndexed(crossinline f: suspend (index: Int, A) -> B): List<B> =
+    runBlocking {
+        mapIndexed { index, it -> async(Dispatchers.Default) { f(index, it) } }.awaitAll()
+    }
+
+inline fun <A, B> Iterable<A>.parallelMapIndexedNotNull(crossinline f: suspend (index: Int, A) -> B?): List<B> =
+    runBlocking {
+        mapIndexed { index, it -> async(Dispatchers.Default) { f(index, it) } }.awaitAll().filterNotNull()
+    }
+
+inline fun <A, B> Iterable<A>.parallelFlatMap(crossinline f: suspend (A) -> Iterable<B>): List<B> =
+    runBlocking {
+        map { async(Dispatchers.Default) { f(it) } }.awaitAll().flatten()
+    }
+
+inline fun <A, B> Iterable<A>.parallelFlatMapIndexed(crossinline f: suspend (index: Int, A) -> Iterable<B>): List<B> =
+    runBlocking {
+        mapIndexed { index, it -> async(Dispatchers.Default) { f(index, it) } }.awaitAll().flatten()
+    }

library/src/main/java/eu/kanade/tachiyomi/util/JsonExtensions.kt

@@ -0,0 +1,27 @@
+package eu.kanade.tachiyomi.util
+
+import kotlinx.serialization.ExperimentalSerializationApi
+import kotlinx.serialization.decodeFromString
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.okio.decodeFromBufferedSource
+import kotlinx.serialization.serializer
+import okhttp3.Response
+import uy.kohesive.injekt.Injekt
+import uy.kohesive.injekt.api.get
+
+inline fun <reified T> Response.parseAs(transform: (String) -> String): T {
+    val responseBody = use { transform(it.body.string()) }
+    return Injekt.get<Json>().decodeFromString(responseBody)
+}
+
+@ExperimentalSerializationApi
+inline fun <reified T> Response.parseAs(): T = use { res ->
+    res.body.source().use {
+        Injekt.get<Json>().decodeFromBufferedSource(serializer(), it)
+    }
+}
+
+inline fun <reified T> String.parseAs(transform: (String) -> String): T =
+    Injekt.get<Json>().decodeFromString(transform(this))
+
+inline fun <reified T> String.parseAs(): T = Injekt.get<Json>().decodeFromString(this)

library/src/main/java/eu/kanade/tachiyomi/util/JsoupExtensions.kt

@@ -9,4 +9,4 @@ import org.jsoup.nodes.Document
  */
 fun Response.asJsoup(html: String? = null): Document {
     throw Exception("Stub!")
-}
+}