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.