Any idea why this code is not returning? It keeps suspended forever ```userRepository.streamUser()....

# coroutines

[Ahmed Ibrahim]

Any idea why this code is not returning? It keeps suspended forever

userRepository.streamUser().filterLoggedIn().firstOrNull()

The repository returns a Logged Out user, but I'm only interested in logged in users, I would expect that since this flow becomes an empty flow, then firstOrNull should return null, right or am I missing something?

[zak.taccardi]

filterLoggedIn() doesn’t emit anything, and doesn’t complete, so firstOrNull() won’t emit IIRC

[Ahmed Ibrahim]

fun Flow<UserResult>.filterLoggedIn(): Flow<UserResult.LoggedIn> =
    filterIsInstance()

That's the implementation of it, it is just a mere filterIsInstance

[octylFractal]

it would rely on streamUser() completing, otherwise how would it know if it's empty?

[Ahmed Ibrahim]

Yeah, you are right, the key is on the completion of the flow.
I changed the code to

userRepository.streamUser().take(1).filterLoggedIn().firstOrNull()

and it is working as expected, thanks everyone.

[zak.taccardi]

userRepository.streamUser().firstOrNull { .. }

[zak.taccardi]

you can use a custom predicate IIRC

[octylFractal]

as I understand that would have the same issue

[zak.taccardi]

oh, yeah

[zak.taccardi]

🤦