`buildSequence getThingBlocking forEach ` kotlinlang #announcements

Channels

kotlin-foundation

compose-android

ohio-kotlin-users

kotlin-by-example

sofl-user-group

kotlin-multiplatform-contest

tricity-kotlin-user-group

kotlin-in-action

android-databinding

cincinnati-user-group

fluid-libraries

codemash-precompiler

kotlingforbeginners

jhipster-kotlin

prozis-android-backup

realworldkotlin

graviton-browser

spring-security

domain-driven-design

connect-audit-events

swiss-user-group

effectivekotlin

refactoring-to-kotlin

russian-kotlinasfirst

androidgithubprojects

introduce-yourself

pocketgitclient

effective-kotlin

algolialibraries

lambdaworld_cadiz

intellij-tricks

kotlin-pakistan

navigation-architecture-component

strife-discord-lib

machinelearningbawas

leedskotlinusergroup

stayhungrystayfoolish

kotest-contributors

practical-functional-programming

swagger-gradle-codegen

100daysofkotlin

kotlinultimatechallenge

pattern-matching

kotlinforbeginners

competitive-programming

compose-ui-showcase

competitivecoding

kotlin-data-storage

skia-wasm-interop-temp

java-to-kotlin-refactoring

event21-community-content

androidx-xprocessing

embedded-kotlin

fb-internal-demo

image-processing

myndocs-oauth2-server

kotlintest-devs

beepiz-libraries

kotlinprogrammers

cscenter-course-2016

k2-early-adopters

intellij-plugins

language-proposals

library-development

refreshversions

language-evolution

kotlinx-datetime

framework-elide

compose-desktop

jvm-ir-backend-feedback

android-architecture

100daysofkotlin-2021

github-workflows-kt

python-contributors

squarelibraries

arrow-contributors

codingconventions

getting-started

Title

k

karelpeeters

12/26/2017, 4:18 PM

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

z

ziggy42

12/26/2017, 4:25 PM

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

.

k

karelpeeters

12/26/2017, 4:26 PM

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

z

ziggy42

12/26/2017, 4:27 PM

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

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

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

This works

k

karelpeeters

12/26/2017, 4:47 PM

Yup, forgot to put

yield

around it.

Actually

generateSequence

would be better.

z

ziggy42

12/26/2017, 4:52 PM

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

Wow

k

karelpeeters

12/26/2017, 4:53 PM

Nice!

4 Views

#announcements Join Slack