Such transactional function:

fun findMessages(): Flow<Foo> {
    return fooRepository.findAll()
}

Currently generates a class kotlinx.coroutines.reactive.PublisherAsFlow cannot be cast to class org.reactivestreams.Publisher error message.