Skip to content

Instantly share code, notes, and snippets.

@bijukunjummen

bijukunjummen/simpleconsumer.kt

Created July 26, 2020 23:58
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/f69e11bd661e723ad8ae3312eae3def2 to your computer and use it in GitHub Desktop.
Save bijukunjummen/f69e11bd661e723ad8ae3312eae3def2 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
simpleconsumer.kt
val delayBetweenConsumes: Long = 1000L / consumerRate
producer.produce(producerRate, count)
    .subscribe { value: Long ->
        sleep(delayBetweenConsumes)
        logger.info("Consumed {}", value)
    }
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment