`buildSequence(::getThingBlocking).forEach { ... }...

# announcements

[karelpeeters]

buildSequence(::getThingBlocking).forEach { ... }

[ziggy42]

mm the while(true) is basically the core of the application, its only purpose is to do something with thing and then to get another thing.

[karelpeeters]

Well the code I just posted does exactly the same as yours.

[ziggy42]

buildSequence<String>({ client.blpop("somekey", "0") })
        .forEach { job -> logger.debug { "New job received: $job" } }

[ziggy42]

I've never used coroutines before. After the first call the process dies. Why?

[ziggy42]

buildSequence<String>({
        while (true)
            client.blpop("somekey", "0").forEach { yield(it) }
    })
        .forEach { job ->
            logger.debug { "New job received: $job" }
        }

[ziggy42]

This works

[karelpeeters]

Yup, forgot to put yield around it.

[karelpeeters]

Actually generateSequence would be better.

[ziggy42]

generateSequence { client.blpop("key", "0")[1] }.forEach { println(it) }

[ziggy42]

Wow

[karelpeeters]

Nice!