Hi, I am not getting how Exception propagation is ...

# coroutines

[nerses]

Hi, I am not getting how Exception propagation is happening. Here is a pseudo code and test

fun populate(hotels: List<Hotel>) {
        
        val context = newFixedThreadPoolContext(threadpoolCoreSize, "thread-geo")

          context.use { c ->
                val jobs = hotels.map { hotel ->
                    launch(c) {
                        repo.suspendableFun()
                    }
                }
                runBlocking(c) {
                    jobs.forEach({ it.join() })
                }
            }
  }

and

@Test(expectedExceptions = [RuntimeException::class])
    fun `populate should throw exceptionIn`() = runBlocking {
        //and
        given(repo.suspendableFun()).willThrow(RuntimeException(""))

        //when
        victim.populate(hotelList())

        //then
        //The exception is thrown
    }

[Ilmir Usmanov [JB]]

Try to replace suspendFun with suspendableFun.

[nerses]

it’s the same, sorry

[nerses]

i was just simplifying the code to post here

[Ilmir Usmanov [JB]]

Yes, I reproduced the problem. Will file the issue shortly. Thank you!

[Ilmir Usmanov [JB]]

BTW, if I throw the exception in suspendableFun, without mocking it, the exception is propagated as expected.

[nerses]

oh, so it’s a genuine bug 🙂 I was thinking i am doing something wrong 🙂

[nerses]

@Ilmir Usmanov [JB] can you give me the ticket number once you’ve created it?

[Ilmir Usmanov [JB]]

Sure: https://youtrack.jetbrains.com/issue/KT-22774

[nerses]

thanks @Ilmir Usmanov [JB]