sendMessagesFlow
fun QueueAsyncClient.sendMessagesFlow(upstream: Flow<SendMessageRequest>, concurrency: Int = 100): Flow<SendMessageResult>
Sends messages to an Azure Storage Queue using an upstream flow of SendMessageRequest objects.
Return
A flow of SendMessageResult objects.
Example usage:
val queueAsyncClient = QueueClientBuilder().queueName("name").buildAsyncClient()
val messagesToSend = flowOf(SendMessageRequest("Hello, River!"))
val sendFlow = queueAsyncClient.sendMessagesFlow(messagesToSend)
sendFlow.collect { result -> println("Message sent: ${result.messageId}") }Content copied to clipboard
Parameters
upstream
The flow of SendMessageRequest objects to send to the queue.
concurrency
The concurrency for this operation. Defaults to 100.