Package-level declarations
Functions
Link copied to clipboard
fun SnsAsyncClient.publishFlow(upstream: Flow<PublishMessageRequest>, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(10, 250.milliseconds), topicArn: suspend () -> String): Flow<PublishMessageResponse>
The publishFlow function is used to publish messages concurrently to an Amazon Simple Notification Service (SNS) topic using a SnsAsyncClient.