Skip to content

Instantly share code, notes, and snippets.

@bijukunjummen

bijukunjummen/slowconsumerflatmap.kt

Created July 27, 2020 00:11
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/ff3745cc26914851255f314bf08fd3b6 to your computer and use it in GitHub Desktop.
Save bijukunjummen/ff3745cc26914851255f314bf08fd3b6 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
slowconsumerflatmap.kt
producer.produce(producerRate, count)
    .subscribeOn(subscribeOnScheduler)
    .publishOn(publishOnScheduler, 10)
    .flatMap({ value: Long ->
        Mono.fromSupplier {
            sleep(delayBetweenConsumes)
            logger.info("Consumed {}", value)
            null
        }.subscribeOn(flatMapScheduler)
    }, concurrency)
    .subscribe()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment