Support Kotlin

1. Avantages

Kotlin offre plusieurs avantages par rapport à Java lorsqu’il s’agit de développer des applications réactives.

// Java 
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); 
List<Integer> squaredNumbers = numbers.stream() 
                                     .map(n...

1. Null safety étendue

Reactor va plus loin en fournissant une null safety pour l’ensemble de son API grâce à des annotations déclarées dans le package reactor.util.annotation. Les développeurs Kotlin bénéficient ainsi d’une sécurité nulle complète, même avec des types Java utilisés dans Kotlin. Les vérifications JSR 305 peuvent être configurées pour renforcer la sécurité nulle selon les besoins du projet. Bien que certaines fonctionnalités ne soient pas encore totalement prises en charge, l’équipe prévoit de les inclure dans les prochaines versions. Vous pouvez configurer les vérifications JSR 305 en ajoutant l’indicateur de compilateur -Xjsr305 avec les options suivantes : -Xjsr305={strict|warn|ignore}.

2. Types réifiés

Les paramètres de type réifiés en Kotlin sont une fonctionnalité qui permet de conserver...

1. CRUD simple

Voici un exemple d’application Spring WebFlux en Kotlin qui expose un CRUD pour l’entité utilisateur.

data class User(val id: Long, val name: String, val email: String) 

interface UserRepository { 
    fun findAll(): Flux<User> 
    fun findById(id: Long): Mono<User> 
    fun save(user: User): Mono<User> 
    fun update(id: Long, user: User): Mono<User> 
    fun delete(id: Long): Mono<Void> 
}  

@Component 
class InMemoryUserRepository : UserRepository { 
 
    private val users = ConcurrentHashMap<Long, User>() 
 
    override fun findAll(): Flux<User> { 
        return Flux.fromIterable(users.values) 
    } 
 
    override fun findById(id: Long): Mono<User> { 
        return Mono.justOrEmpty(users[id]) 
    } 
 
    override fun save(user: User): Mono<User> { 
        users[user.id] = user 
        return Mono.just(user) 
    } 
 
    override fun update(id: Long, user: User): Mono<User> { 
        if (users.containsKey(id)) { 
            users[id] = user 
            return Mono.just(user) 
        } 
        return Mono.empty() 
    } 
 
    override fun delete(id: Long): Mono<Void> { 
        users.remove(id) 
        return...