codinux
/
eInvoicing
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Removed unnecessary async { }

This commit is contained in:
dankito 2024-11-27 03:35:19 +01:00
parent 1e372cf592
commit c65d99e35d
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
e-invoice-domain/src/main/kotlin/net/codinux/invoicing/email/EmailsFetcher.kt
View File

@ -117,23 +117,21 @@ open class EmailsFetcher(
return@runBlocking emptyList() return@runBlocking emptyList()
} }
async(coroutineDispatcher) { val startUid = max(status.options.lastRetrievedMessageId?.let { it + 1 } ?: 0, 1) // message numbers start at 1
val startUid = max(status.options.lastRetrievedMessageId?.let { it + 1 } ?: 0, 1) // message numbers start at 1
folder.getMessagesByUID(startUid, UIDFolder.MAXUID).mapNotNull { message -> folder.getMessagesByUID(startUid, UIDFolder.MAXUID).mapNotNull { message ->
async(coroutineDispatcher) { async(coroutineDispatcher) {
try { try {
getEmail(message, status) getEmail(message, status)
} catch (e: Throwable) { } catch (e: Throwable) {
log.error(e) { "Could not get email $message" } log.error(e) { "Could not get email $message" }
status.addError(FetchEmailsErrorType.GetEmail, message, e) status.addError(FetchEmailsErrorType.GetEmail, message, e)
null null
}
} }
} }
.awaitAll() }
.filterNotNull() .awaitAll()
}.await() .filterNotNull()
} }
protected open fun getEmail(message: Message, status: FetchEmailsStatus): Email? { protected open fun getEmail(message: Message, status: FetchEmailsStatus): Email? {