Merge "Catch crash for broadcastReceiverFlow" into main

import android.content.Context

import android.content.Intent

import android.content.IntentFilter

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 = "BroadcastReceiverFlow"

/**

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

 */

    registerReceiver(broadcastReceiver, intentFilter, Context.RECEIVER_NOT_EXPORTED)

    awaitClose { unregisterReceiver(broadcastReceiver) }

}.catch { e ->

    Log.e(TAG, "Error while broadcastReceiverFlow", 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.mock

import org.mockito.kotlin.stub

@RunWith(AndroidJUnit4::class)

class BroadcastReceiverFlowTest {

        assertThat(onReceiveIsCalled).isTrue()

    }

    @Test

    fun broadcastReceiverFlow_unregisterReceiverThrowException_noCrash() = runBlocking {

        context.stub {

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

        }

        val flow = context.broadcastReceiverFlow(INTENT_FILTER)

        flow.firstWithTimeoutOrNull()

        assertThat(registeredBroadcastReceiver).isNotNull()

    }

    private companion object {

        val INTENT_FILTER = IntentFilter()

    }