[Bug]: CancellationExceptions are not always rethrown

[sproctor]

General Info

• I checked for similar bug report
• I am using the latest version
• I checked the troubleshooting page for similar problems

Version(s)

3.1.3

Kotlin Target(s) and their respective versions

All

What happened? (include your code)

I'm getting logged exceptions being handled from cancelled coroutines. Any try/catch containing a suspend call should check for and rethrow CancellationExceptions.

My code triggering this:

coroutineScope {
  val channel = supabase.realtime.channel("db-changes")
  channel.postgresChangeFlow<PostgresAction>(schema = "public") {
              ...
  }
  .onEach { ... }
  .launchIn(this)
  channel.subscribe(true)
  try {
    awaitCancellation()
  } finally {
    withContext(NonCancellable) {
      channel.unsubscribe()
      supabase.realtime.removeChannel(channel)
    }
  }
}

Steps To Reproduce (optional)

No response

Relevant log output (optional)

Unfortunately, I'm not getting the full stacktrace in my logs.

ChildCancelledException: Child of the scoped flow was cancelled

[jan-tennert]

So trying to reproduce this, how exactly is this exception triggered? My repro code:

    coroutineScope {
        val job = launch {
            val channel = supabase.realtime.channel("db-changes")
            channel.postgresChangeFlow<PostgresAction>(schema = "public") {
                table = "messages"
            }
                .onEach { println(it) }
                .launchIn(this)
            channel.subscribe(true)
            try {
                awaitCancellation()
            } finally {
                withContext(NonCancellable) {
                    channel.unsubscribe()
                    supabase.realtime.removeChannel(channel)
                }
            }
        }
        delay(2000)
        job.cancel()
    }

[sproctor]

I think it only happens when the access token is expired. This catch seems to be the problematic one:

supabase-kt/Realtime/src/commonMain/kotlin/io/github/jan/supabase/realtime/RealtimeImpl.kt

Line 85 in c4163bb

} catch(e: Exception) {

[sproctor]

Fixed by PR #895