Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy un poco confundido sobre cómo funcionan exactamente las excepciones en los flujos de Kotlin. Al ver este código de muestra de https://developer.android.com/kotlin/flow#exceptions: class NewsRepository(…) { val favoriteLatestNews: Flow<><articleheadline>> = newsRemoteDataSource.latestNews .map { news -> news.filter { userData.isFavoriteTopic(it) } } .onEach { news -> saveInCache(news) } // Si ocurre un . . . Read more
Ok, así que quiero empezar a usar Kotlin-Flow como hacen todos los chicos guays. Parece que lo que quiero hacer se ajusta a este patrón reactivo. Así que recibo un mensaje de Firebase en segundo plano. … override fun onMessageReceived(remoteMessage: RemoteMessage) { super.onMessageReceived(remoteMessage) val msg = gson.fromJson(remoteMessage.data["data"], MyMessage::class.java) // persistir . . . Read more
Tengo una consulta de base de datos que devuelve la lista de índices de objetos para un día determinado, es decir: kotlin getIndexesOfDay(día: Day): Flow<List> Ahora necesito escuchar los detalles de cada índice, por ejemplo: kotlin getDetailsByIndex(index: String): Flow Entonces, la pregunta es: ¿cómo puedo lograr esto usando Flows? Dos . . . Read more
Estoy usando Apollo GraphQL en Android. Estoy usando la versión 3 de Apollo. Tengo una suscripción y puedo suscribirme con éxito y recibir las actualizaciones. El problema es que si activo el modo de vuelo, la aplicación falla con la excepción: java.lang.IllegalStateException: WeSocket queue full at com.apollographql.apollo3.network.ws.DefaultWebSocketEngine$open$3.send(OkHttpWebSocketEngine.kt:90) at com.apollographql.apollo3.network.ws.WsProtocol.sendMessageMapBinary(WsProtocol.kt:92) at . . . Read more
Imagínese que tengo estas dos fuentes de datos: val flowA: Flow suspend fun funB(): Int ¿Cómo puedo combinar el resultado de ambos en un flujo (digamos Flow<Pair<String, Int>>)? ¿Qué tal el enfoque a continuación? ¿Hay una mejor manera? combina ( flujoA, flujo {emit(funB())} ) { a, b -> … }