Hello I have MutableStateFlow with string data as state in P kotlinlang #flow

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

s

Sanendak

04/07/2021, 5:31 PM

Hello! I have MutableStateFlow (with string data as state) in PhoneStateListener class. I want to collect this flow in another class, where listener provides in constructor (repository). But this works only first time.

private val _state = MutableStateFlow("initial")
val state: StateFlow<String> = _state

How i change state:

_state.value = "ringing"

How collected:

fun getCallLog() = flow<String> {
    listenerService.state.collect {
        Log.d("CALL STATE", it)
        emit(it)
    }
}

When I collect in the same place where I create StateFlow all works fine.

b

baxter

04/07/2021, 5:46 PM

So you should make your state flow immutable in your ListenerService as such:

val state: StateFlow<String> = _state.asStateFlow()

Then, instead of wrapping the state flow, you can just pass it back directly when you call

getCallLog()

. Each time you collect the flow, it'll emit the latest item as well as all subsequent ones.

If you want to keep your debug log, you can do:

fun getCallLog(): Flow<String> = listenerService.state.onEach { Log.d("CALL STATE", it) }

s

Sanendak

04/07/2021, 5:52 PM

Thanks! It work!

#flow Join Slack