Emit Flow via another suspend function in Kotlin - TagMerge

Emit Flow via another suspend function in Kotlin

Asked 1 years ago

2

2 answers

You can try to use emitAll function for your case:

fun myFunction1(): Flow<String> = flow {
    /*some code*/
    emitAll(myFunction2())
}

fun myFunction2(): Flow<String> = flow {
    /*some code*/
    emit("hello")
}

emitAll function collects all the values from the Flow, created by myFunction2() function and emits them to the collector.

And there is no reason to set a suspend modifier before each function, flow builder isn't suspend.

Source: link

Some random IT boyAnswered 1 years ago

1

Unless you have a very specific reason the functions returning a Flow from your repo shouldn't be suspending (As the flow{} builder isn't suspending). Since the suspending operation is collecting (waiting for values to come out of it).

From the code you've provided you're looking for the flatMapLatest function. Docs here

class Repo {

  fun function1() = 
    flow {
      val value = doSomething()
      emit(value)
    }
    .flatMapLatest { emittedValue -> function2() }
  fun function2() = flow {...}
}

Source: link

Write an answer

Emit Flow via another suspend function in Kotlin

Suspend function 'callGetApi' should be called only from a coroutine or another suspend function

How can I use data from another flow data in flow? (Kotlin Flow)

Kotlin Flow How to combine two flows and only emit the result when the first flow sends element

Combine two kotlin flows into a single flow that emits the latest value from the two original flows?

emitting flow values asynchronously with kotlins flow

How to execute a lambda function which copies objects from one S3 bucket to another via Step functions?

How to initialize a flow in viewmodel with a suspend function as parameter

how to return an object in a suspended function after receiving the object from a Flow?

how to get function on fragment and use it in another class on Kotlin

Filter a list inside forEach function of another list - Kotlin

Using emit to build a Kotlin flow runs indefinitely and doesnt complete

Why my kotlin suspend function don't throw error? And continue to nextline?

Kotlin flow - Is flow created once for each collector?

Why can't the emit() operation of Flow after emitAll() be launched in Kotlin ? and onCompletion{} can't be launched too

Kotlin unit test Exception when mocking suspend function java.io.EOFException: Premature end of stream: expected 1 bytes

combining pagingData 3 flow with another flow

How to debug a function that has been passed as an argument to another function

React - Calling function from another function does not work

passing functions into another function, resulting in ValueError

Recent Questions on kotlin

Programming Languages