Has anyone tried sqs message consumer using Kotlin...
# coroutines
t
Has anyone tried sqs message consumer using Kotlin flow???
g
Not sure what your use case is or want part would be hard. I used it with Kafka, using broadcast to send messages to multiple channels. https://github.com/openweb-nl/kafka-graphql-examples/blob/886e36a37362e0a7d37974738cc4453477dfadf2/graphql-endpoint/src/main/kotlin/nl/openweb/graphql_endpoint/service/TransactionService.kt#L75
t
Okay. Basically I want to check is it possible to convert this channel logic to use flow? https://jivimberg.io/blog/2019/02/23/sqs-consumer-using-kotlin-coroutines/
141 Views