优化
This commit is contained in:
@@ -138,7 +138,7 @@ class ImportBookViewModel(application: Application) : BaseViewModel(application)
|
|||||||
channel.trySend(fileDoc)
|
channel.trySend(fileDoc)
|
||||||
val list = arrayListOf<FileDoc>()
|
val list = arrayListOf<FileDoc>()
|
||||||
channel.consumeAsFlow()
|
channel.consumeAsFlow()
|
||||||
.mapParallel(64) { fileDoc ->
|
.mapParallel(16) { fileDoc ->
|
||||||
fileDoc.list()!!
|
fileDoc.list()!!
|
||||||
}.onEach { fileDocs ->
|
}.onEach { fileDocs ->
|
||||||
n--
|
n--
|
||||||
|
|||||||
Reference in New Issue
Block a user