Estoy trabajando con un proyecto de Android que necesita inicializar el token de Firebase. Principalmente trabajando con rutinas de Kotlin, me gustaría implementar el código línea por línea, pero dado que no hay forma de solicitar de forma sincrónica el token de Firebase, se me ocurrió la solución para envolver OnCompleteListener usando la siguiente función:

 private suspend fun fcmCallbackSuspendWrapper(block: (OnCompleteListener<InstanceIdResult>) -> Unit) = suspendCancellableCoroutine<Task<InstanceIdResult>> { cont -> block(OnCompleteListener { response -> cont.resume(response) }) }

Básicamente, bloquea el hilo actual hasta que Task llama a la devolución de llamada. Luego estoy aplicando dicha función en mi código de la siguiente manera:

 val fcmInstance = fcmCallbackSuspendWrapper { listener -> fireBaseInstanceIdProvider .provide() // Returns Firebase instance .instanceId // Returns Task<InstanceIdResult> .addOnCompleteListener(listener) // Sets listener to block current thread until completed }

Pero ahora necesito agregar una prueba unitaria al código anterior y aquí encuentro varios problemas:

 @Mock lateinit var instanceIdResultTaskMock: Task<InstanceIdResult> @Mock lateinit var fireBaseInstanceIdProviderMock: Provider<FirebaseInstanceId> @Mock lateinit var firebaseInstanceIdMock: FirebaseInstanceId ... Mockito.`when`(fireBaseInstanceIdProviderMock.provide()).thenReturn(firebaseInstanceIdMock) Mockito.`when`(firebaseInstanceIdMock.instanceId).thenReturn(instanceIdResultTaskMock)

Pero dado que Task<InstanceIdResult> se burla, nunca se llama a OnCompleteListener<TResult> y el subproceso se bloquea para siempre, preservando la ejecución del código para continuar. ¿Qué se puede hacer en esta situación?