Merge "Catch crash for broadcastReceiverAsUserFlow" into main

import android.content.Intent

import android.content.IntentFilter

import android.os.UserHandle

import android.util.Log

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.channels.awaitClose

import kotlinx.coroutines.flow.Flow

import kotlinx.coroutines.flow.callbackFlow

import kotlinx.coroutines.flow.catch

import kotlinx.coroutines.flow.conflate

import kotlinx.coroutines.flow.flowOn

private const val TAG = "BroadcastReceiverAsUser"

/**

 * A [BroadcastReceiver] flow for the given [intentFilter].

 */

    )

    awaitClose { unregisterReceiver(broadcastReceiver) }

}.catch { e ->

    Log.e(TAG, "Error while broadcastReceiverAsUserFlow", e)

}.conflate().flowOn(Dispatchers.Default)

import org.junit.runner.RunWith

import org.mockito.kotlin.any

import org.mockito.kotlin.doAnswer

import org.mockito.kotlin.doThrow

import org.mockito.kotlin.eq

import org.mockito.kotlin.isNull

import org.mockito.kotlin.mock

import org.mockito.kotlin.stub

@RunWith(AndroidJUnit4::class)

class BroadcastReceiverAsUserFlowTest {

        assertThat(onReceiveIsCalled).isTrue()

    }

    @Test

    fun broadcastReceiverAsUserFlow_unregisterReceiverThrowException_noCrash() = runBlocking {

        context.stub {

            on { unregisterReceiver(any()) } doThrow IllegalArgumentException()

        }

        val flow = context.broadcastReceiverAsUserFlow(INTENT_FILTER, USER_HANDLE)

        flow.firstWithTimeoutOrNull()

        assertThat(registeredBroadcastReceiver).isNotNull()

    }

    private companion object {

        val USER_HANDLE: UserHandle = UserHandle.of(0)