Package-level declarations
Functions
Link copied to clipboard
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.
Link copied to clipboard
fun QueueAsyncClient.receiveMessagesAsFlow(concurrency: ConcurrencyStrategy = ConcurrencyStrategy.disabled, pollSize: Int = 32, visibilityTimeout: Duration = 30.seconds, stopOnEmptyList: Boolean = false): Flow<QueueMessageItem>
Continuously receives messages from an Azure Storage Queue using the provided QueueAsyncClient. The received messages are returned as a Flow of QueueMessageItem objects.
Link copied to clipboard
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.