Hey to all Quick question How can I use flow to emit a value kotlinlang #coroutines

Channels

100daysofkotlin

100daysofkotlin-2021

algolialibraries

android-architecture

android-databinding

androidgithubprojects

androidx-xprocessing

arrow-contributors

beepiz-libraries

cincinnati-user-group

codemash-precompiler

codingconventions

competitive-programming

competitivecoding

compose-android

compose-desktop

compose-ui-showcase

connect-audit-events

cscenter-course-2016

domain-driven-design

effective-kotlin

effectivekotlin

embedded-kotlin

event21-community-content

fb-internal-demo

fluid-libraries

framework-elide

getting-started

github-workflows-kt

graviton-browser

image-processing

intellij-plugins

intellij-tricks

introduce-yourself

java-to-kotlin-refactoring

jhipster-kotlin

jvm-ir-backend-feedback

k2-early-adopters

kotest-contributors

kotlin-by-example

kotlin-data-storage

kotlin-foundation

kotlin-in-action

kotlin-multiplatform-contest

kotlin-pakistan

kotlinforbeginners

kotlingforbeginners

kotlinprogrammers

kotlintest-devs

kotlinultimatechallenge

kotlinx-datetime

lambdaworld_cadiz

language-evolution

language-proposals

leedskotlinusergroup

library-development

machinelearningbawas

myndocs-oauth2-server

navigation-architecture-component

ohio-kotlin-users

pattern-matching

pocketgitclient

practical-functional-programming

prozis-android-backup

python-contributors

realworldkotlin

refactoring-to-kotlin

refreshversions

russian-kotlinasfirst

skia-wasm-interop-temp

sofl-user-group

spring-security

squarelibraries

stayhungrystayfoolish

strife-discord-lib

swagger-gradle-codegen

swiss-user-group

tricity-kotlin-user-group

Title

k

koufa

01/23/2020, 2:56 PM

Hey to all. Quick question. How can I use flow to emit a value every X seconds for example ? Is there any API available or do I have to build a Flow myself ?

d

dekans

01/23/2020, 2:57 PM

fun foo(): Flow<Int> = flow {
    for (i in 1..3) {
        delay(100)
        emit(i)
    }
}

Something like that?

k

koufa

01/23/2020, 3:02 PM

Yes exactly that's how I intend to build it myself. Was only asking if there was already an function available where you just put a value generator and a delay duration. But thanks anyways

Or analogous to the

interval

from Rx. But it is astonishingly easy to create that yourself with flow so probably they keep the API small

👍 1

b

bdawg.io

01/24/2020, 12:41 AM

You can also use a

Sequence

to generate the numbers and convert it to a flow that's delayed

generateSequence(0) { it + 1 }
    .asFlow()
    .delayEach(100)
    ...

or in his example above

(1..3).asFlow().delayEach(100)

It ends up coming down to syntax preference and what makes sense for your use case though :)

j

Jason

01/24/2020, 2:01 AM

You mean you need a operator like

emitByPeriod()

or something like that ?

👍 1

5 Views

#coroutines Join Slack