A modern programming language that makes developers happier.

kotlinlang

TLDR; this is what worries me more, is there anything wrong here?
```
override suspend fun observeCount() = coroutineScope {
    queries.count().asChannel().mapToOne( coroutineContext ).map { it.toInt() }
}
```

```
fun &lt;T : Any&gt; ReceiveChannel&lt;Query&lt;T&gt;&gt;.mapToOne( context: CoroutineContext ) =
    map( context ) { it.executeAsOne() }
```

What are you expecting exactly in this snippet, and what happens exactly at runtime instead?

I expect the ViewModel to receive the UiModel's from the Presenter, but it doesn't :sweat_smile:

I see that the Channel created from the listener `offers` the Queries, but presenter never receive them

<@U3ZLHBTLG>  you should take a look at the full snippet above for get a better idea :slightly_smiling_face: it's 90 lines of code but half are empty and very easy to understand :yum:

-.kt

<https://kotlinlang.slack.com/files/UFH9XK3UJ/FGLE6L4D9/-.kt>

There's a problem in invokeOnClose, you don't seem to pass a proper lambda. Also, the indentation doesn't follow the convention, I'm not sure why you didn't reformat at least to post here

The observe function of your presenter can't return until the channels are closed because the coroutines launched in the scope are not finished. You should not have it a suspending function but have it a regular function, extension for `CoroutineScope` instead.

I'm not getting it :thinking_face: the function on presenter correctly reaches its end :thinking_face: I will give a try, but I didn't really get it :grin:

Why you saying the lambda on `invokeOnClose` is not right? The indentation stuff it's about AS beta that indentates wrongly, don't ask me why

You can edit Kotlin code style, loading it from convention.

You mean you no longer have a problem with this code?

Yep, I did some edit for get rid of the other `coroutineScope {  }`

But I didn't get why it's working now :white_frowning_face: could you explain or give me so useful link? 

As stated in the docs, the `coroutineScope { … }` function suspends until all coroutines launched inside it are completed or cancelled.