Las corrutinas de Kotlin y Arrow son una buena manera de evitar anidar mapas planos, introduciendo comprensiones monádicas en Kotlin. Sin embargo, el tipo de Flow de Kotlin todavía se basa en mapas planos declarativos, por lo que entramos en una mezcla de estilos directos y declarativos:
override suspend fun findAll(page: Pageable): Either<BusinessException, Flow<PageElement<ClientOut>>> = either { val count = clientRepository.count().awaitSingle().bind() return clientRepository.findByIdNotNull(page).asFlow() .flatMapMerge { client -> flow { emit(mapDetailedClientOut(client)) } } } val count se ha vinculado dentro either {...} comprensión. Sin embargo, no parece haber una forma de hacer lo mismo con Flow , lo que nos obliga a anidar un flatmapMerge() .
¿Hay alguna manera de hacerlo, o está planeado incluirlo de alguna manera en un futuro cercano?
Lamentablemente, actualmente no hay forma de crear comprensiones para el tipo de datos KotlinX Flow , ya que las corrutinas en Kotlin solo son compatibles con la emisión/ bind de un solo disparo.
Por lo tanto, solo es posible crear comprensiones para tipos de datos con elementos 0..1 , como Either o Nullable , pero no 0..N como los tipos de datos Flow o List .