|
|
@@ -45,7 +45,9 @@ import kotlinx.coroutines.*
|
|
|
import kotlinx.coroutines.flow.catch
|
|
|
import kotlinx.coroutines.flow.collectLatest
|
|
|
import kotlinx.coroutines.flow.flow
|
|
|
+import kotlinx.coroutines.flow.mapLatest
|
|
|
|
|
|
+@ExperimentalCoroutinesApi
|
|
|
class BookSourceActivity : VMBaseActivity<ActivityBookSourceBinding, BookSourceViewModel>(),
|
|
|
PopupMenu.OnMenuItemClickListener,
|
|
|
BookSourceAdapter.CallBack,
|
|
|
@@ -207,6 +209,7 @@ class BookSourceActivity : VMBaseActivity<ActivityBookSourceBinding, BookSourceV
|
|
|
searchView.setOnQueryTextListener(this)
|
|
|
}
|
|
|
|
|
|
+
|
|
|
private fun upBookSource(searchKey: String? = null) {
|
|
|
sourceFlowJob?.cancel()
|
|
|
sourceFlowJob = launch {
|
|
|
@@ -232,43 +235,43 @@ class BookSourceActivity : VMBaseActivity<ActivityBookSourceBinding, BookSourceV
|
|
|
}
|
|
|
}.catch {
|
|
|
AppLog.put("书源界面更新书源出错", it)
|
|
|
- }.collectLatest { data ->
|
|
|
- val sourceList =
|
|
|
- if (sortAscending) when (sort) {
|
|
|
- Sort.Weight -> data.sortedBy { it.weight }
|
|
|
- Sort.Name -> data.sortedWith { o1, o2 ->
|
|
|
- o1.bookSourceName.cnCompare(o2.bookSourceName)
|
|
|
- }
|
|
|
- Sort.Url -> data.sortedBy { it.bookSourceUrl }
|
|
|
- Sort.Update -> data.sortedByDescending { it.lastUpdateTime }
|
|
|
- Sort.Respond -> data.sortedBy { it.respondTime }
|
|
|
- Sort.Enable -> data.sortedWith { o1, o2 ->
|
|
|
- var sort = -o1.enabled.compareTo(o2.enabled)
|
|
|
- if (sort == 0) {
|
|
|
- sort = o1.bookSourceName.cnCompare(o2.bookSourceName)
|
|
|
- }
|
|
|
- sort
|
|
|
- }
|
|
|
- else -> data
|
|
|
+ }.mapLatest { data ->
|
|
|
+ if (sortAscending) when (sort) {
|
|
|
+ Sort.Weight -> data.sortedBy { it.weight }
|
|
|
+ Sort.Name -> data.sortedWith { o1, o2 ->
|
|
|
+ o1.bookSourceName.cnCompare(o2.bookSourceName)
|
|
|
}
|
|
|
- else when (sort) {
|
|
|
- Sort.Weight -> data.sortedByDescending { it.weight }
|
|
|
- Sort.Name -> data.sortedWith { o1, o2 ->
|
|
|
- o2.bookSourceName.cnCompare(o1.bookSourceName)
|
|
|
+ Sort.Url -> data.sortedBy { it.bookSourceUrl }
|
|
|
+ Sort.Update -> data.sortedByDescending { it.lastUpdateTime }
|
|
|
+ Sort.Respond -> data.sortedBy { it.respondTime }
|
|
|
+ Sort.Enable -> data.sortedWith { o1, o2 ->
|
|
|
+ var sort = -o1.enabled.compareTo(o2.enabled)
|
|
|
+ if (sort == 0) {
|
|
|
+ sort = o1.bookSourceName.cnCompare(o2.bookSourceName)
|
|
|
}
|
|
|
- Sort.Url -> data.sortedByDescending { it.bookSourceUrl }
|
|
|
- Sort.Update -> data.sortedBy { it.lastUpdateTime }
|
|
|
- Sort.Respond -> data.sortedByDescending { it.respondTime }
|
|
|
- Sort.Enable -> data.sortedWith { o1, o2 ->
|
|
|
- var sort = o1.enabled.compareTo(o2.enabled)
|
|
|
- if (sort == 0) {
|
|
|
- sort = o1.bookSourceName.cnCompare(o2.bookSourceName)
|
|
|
- }
|
|
|
- sort
|
|
|
+ sort
|
|
|
+ }
|
|
|
+ else -> data
|
|
|
+ }
|
|
|
+ else when (sort) {
|
|
|
+ Sort.Weight -> data.sortedByDescending { it.weight }
|
|
|
+ Sort.Name -> data.sortedWith { o1, o2 ->
|
|
|
+ o2.bookSourceName.cnCompare(o1.bookSourceName)
|
|
|
+ }
|
|
|
+ Sort.Url -> data.sortedByDescending { it.bookSourceUrl }
|
|
|
+ Sort.Update -> data.sortedBy { it.lastUpdateTime }
|
|
|
+ Sort.Respond -> data.sortedByDescending { it.respondTime }
|
|
|
+ Sort.Enable -> data.sortedWith { o1, o2 ->
|
|
|
+ var sort = o1.enabled.compareTo(o2.enabled)
|
|
|
+ if (sort == 0) {
|
|
|
+ sort = o1.bookSourceName.cnCompare(o2.bookSourceName)
|
|
|
}
|
|
|
- else -> data.reversed()
|
|
|
+ sort
|
|
|
}
|
|
|
- adapter.setItems(sourceList, adapter.diffItemCallback)
|
|
|
+ else -> data.reversed()
|
|
|
+ }
|
|
|
+ }.collectLatest { data ->
|
|
|
+ adapter.setItems(data, adapter.diffItemCallback)
|
|
|
}
|
|
|
}
|
|
|
}
|