karelpeeters
12/26/2017, 4:18 PMbuildSequence(::getThingBlocking).forEach { ... }
ziggy42
12/26/2017, 4:25 PMwhile(true)
is basically the core of the application, its only purpose is to do something with thing
and then to get another thing
.karelpeeters
12/26/2017, 4:26 PMziggy42
12/26/2017, 4:27 PMbuildSequence<String>({ client.blpop("somekey", "0") })
.forEach { job -> logger.debug { "New job received: $job" } }
buildSequence<String>({
while (true)
client.blpop("somekey", "0").forEach { yield(it) }
})
.forEach { job ->
logger.debug { "New job received: $job" }
}
karelpeeters
12/26/2017, 4:47 PMyield
around it.generateSequence
would be better.ziggy42
12/26/2017, 4:52 PMgenerateSequence { client.blpop("key", "0")[1] }.forEach { println(it) }
karelpeeters
12/26/2017, 4:53 PM