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