Skip to content

Instantly share code, notes, and snippets.

@bijukunjummen

bijukunjummen/ProcessInParallel.kt

Created May 3, 2020 01:18
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save bijukunjummen/86fbd0f019160d5f07d62b0626204250 to your computer and use it in GitHub Desktop.
Save bijukunjummen/86fbd0f019160d5f07d62b0626204250 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ProcessInParallel.kt
Flux.generate { sink: SynchronousSink<List<Message>> ->
    val receiveMessageRequest: ReceiveMessageRequest = ReceiveMessageRequest.builder()
        .queueUrl(queueUrl)
        .maxNumberOfMessages(5)
        .waitTimeSeconds(10)
        .build()
 
    val messages: List<Message> = sqsClient.receiveMessage(receiveMessageRequest).messages()
    sink.next(messages)
}
    .flatMapIterable(Function.identity())
    .retry()
    .subscribeOn(Schedulers.newElastic("sub"))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment