This commit is contained in:
InsanusMokrassar 2022-08-04 09:59:05 +06:00
parent 50a8799f9d
commit 2950de29e5

View File

@ -119,6 +119,7 @@ suspend fun <T> ApplicationCall.uniload(
suspend fun ApplicationCall.uniloadMultipart( suspend fun ApplicationCall.uniloadMultipart(
onFormItem: (PartData.FormItem) -> Unit = {}, onFormItem: (PartData.FormItem) -> Unit = {},
onCustomFileItem: (PartData.FileItem) -> Unit = {}, onCustomFileItem: (PartData.FileItem) -> Unit = {},
onBinaryChannelItem: (PartData.BinaryChannelItem) -> Unit = {},
onBinaryContent: (PartData.BinaryItem) -> Unit = {} onBinaryContent: (PartData.BinaryItem) -> Unit = {}
) = safely { ) = safely {
val multipartData = receiveMultipart() val multipartData = receiveMultipart()
@ -135,6 +136,7 @@ suspend fun ApplicationCall.uniloadMultipart(
} }
} }
is PartData.BinaryItem -> onBinaryContent(it) is PartData.BinaryItem -> onBinaryContent(it)
is PartData.BinaryChannelItem -> onBinaryChannelItem(it)
} }
} }
@ -145,6 +147,7 @@ suspend fun <T> ApplicationCall.uniloadMultipart(
deserializer: DeserializationStrategy<T>, deserializer: DeserializationStrategy<T>,
onFormItem: (PartData.FormItem) -> Unit = {}, onFormItem: (PartData.FormItem) -> Unit = {},
onCustomFileItem: (PartData.FileItem) -> Unit = {}, onCustomFileItem: (PartData.FileItem) -> Unit = {},
onBinaryChannelItem: (PartData.BinaryChannelItem) -> Unit = {},
onBinaryContent: (PartData.BinaryItem) -> Unit = {} onBinaryContent: (PartData.BinaryItem) -> Unit = {}
): Pair<Input, T> { ): Pair<Input, T> {
var data: Optional<T>? = null var data: Optional<T>? = null
@ -157,6 +160,7 @@ suspend fun <T> ApplicationCall.uniloadMultipart(
onCustomFileItem(it) onCustomFileItem(it)
} }
}, },
onBinaryChannelItem,
onBinaryContent onBinaryContent
) )
@ -168,6 +172,7 @@ suspend fun <T> ApplicationCall.uniloadMultipartFile(
deserializer: DeserializationStrategy<T>, deserializer: DeserializationStrategy<T>,
onFormItem: (PartData.FormItem) -> Unit = {}, onFormItem: (PartData.FormItem) -> Unit = {},
onCustomFileItem: (PartData.FileItem) -> Unit = {}, onCustomFileItem: (PartData.FileItem) -> Unit = {},
onBinaryChannelItem: (PartData.BinaryChannelItem) -> Unit = {},
onBinaryContent: (PartData.BinaryItem) -> Unit = {}, onBinaryContent: (PartData.BinaryItem) -> Unit = {},
) = safely { ) = safely {
val multipartData = receiveMultipart() val multipartData = receiveMultipart()
@ -204,6 +209,7 @@ suspend fun <T> ApplicationCall.uniloadMultipartFile(
} }
} }
is PartData.BinaryItem -> onBinaryContent(it) is PartData.BinaryItem -> onBinaryContent(it)
is PartData.BinaryChannelItem -> onBinaryChannelItem(it)
} }
} }
@ -214,6 +220,7 @@ suspend fun <T> ApplicationCall.uniloadMultipartFile(
suspend fun ApplicationCall.uniloadMultipartFile( suspend fun ApplicationCall.uniloadMultipartFile(
onFormItem: (PartData.FormItem) -> Unit = {}, onFormItem: (PartData.FormItem) -> Unit = {},
onCustomFileItem: (PartData.FileItem) -> Unit = {}, onCustomFileItem: (PartData.FileItem) -> Unit = {},
onBinaryChannelItem: (PartData.BinaryChannelItem) -> Unit = {},
onBinaryContent: (PartData.BinaryItem) -> Unit = {}, onBinaryContent: (PartData.BinaryItem) -> Unit = {},
) = safely { ) = safely {
val multipartData = receiveMultipart() val multipartData = receiveMultipart()
@ -247,6 +254,7 @@ suspend fun ApplicationCall.uniloadMultipartFile(
} }
} }
is PartData.BinaryItem -> onBinaryContent(it) is PartData.BinaryItem -> onBinaryContent(it)
is PartData.BinaryChannelItem -> onBinaryChannelItem(it)
} }
} }