Hey! I’m new with flow and I’ve been pondering how to implement the following data flow. My use case...

# flow

[Matti MK]

Hey! I’m new with flow and I’ve been pondering how to implement the following data flow. My use case is that I’m using TMDB API with two endpoints: one to fetch a list of genres and second to fetch a list of movies per genre. This means that if the API returns N genres I have to make N requests to fetch the list of movies. My repository returns a flow of these objects, for example Flow<List<Genre> and Flow<List<Movie>>.

My question is, what would be a flow way of “combining” these two streams, so that once the genres stream emits a value (it will only emit one value, all the genres), the genres would be looped over and movies would be queried for each, then those two combined.

If I were to do this without flow I’d do something like:

fun fetchData() {
   val genresWithMovies: List<GenreWithMovies> = dataSource.queryGenres().map { genre ->
        val movies = dataSource2.queryMovies(genre.id)
        genre.movies = movies
        genre
   }
}

Any tips?

[Matti MK]

Also posted on #android-architecture

[DALDEI]

(Ignoring the bit where 'queryGenres()' returns an object an always empty 'movies' property to be filled in vs a new object with genre + movie )

Yes this will work -- or something close. It may not perform optimally depending on the characteristics of the 2 APIs - this query each genre one by one.

You mention the database returns a Flow but your function signature is List.
You are missing the 'collect' part.
As written the function will not compile.
If you want to return a List then change the map to collectToList()
or add a .toList()
However that will not complete until all genere's are queried.
You an return the flow directly, if your calling code can read flows - then they would get each genre (with movie list) one a time.