deleteMessagesFlow
fun QueueAsyncClient.deleteMessagesFlow(upstream: Flow<QueueMessageItem>, concurrency: Int = 100): Flow<Unit>
Deletes messages from an Azure Storage Queue using an upstream flow of QueueMessageItem objects.
Return
A flow of Unit objects.
Example usage:
val queueAsyncClient = QueueClientBuilder().queueName("name").buildAsyncClient()
val messagesFlow = queueAsyncClient.receiveMessagesAsFlow()
val deleteFlow = queueAsyncClient.deleteMessagesFlow(messagesFlow)
deleteFlow.collect { println("Message deleted") }Content copied to clipboard
Parameters
upstream
The flow of QueueMessageItem objects to delete from the queue.
concurrency
The concurrency for this operation. Defaults to 100.