Soporte para Kotlin

1. Beneficios

Kotlin ofrece varias ventajas sobre Java a la hora de desarrollar aplicaciones reactivas.

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

1. Null safety  extension

Reactor va más allá proporcionando una null safety para toda su API utilizando anotaciones declaradas en el paquete reactor.util.annotation. Esto proporciona a los desarrolladores de Kotlin una seguridad nula completa, incluso con tipos Java utilizados en Kotlin. Las verificaciones de JSR 305 pueden configurarse para reforzar la seguridad nula según las necesidades del proyecto. Aunque algunas características aún no están totalmente soportadas, el equipo planea incluirlas en futuras versiones. Puede configurar las comprobaciones JSR 305 añadiendo el indicador del compilador -Xjsr305 con las siguientes opciones: -Xjsr305={strict|warn|ignore}.

2. Tipos reificados

Los parámetros de tipo reificados en Kotlin son una funcionalidad que permite retener información sobre tipos genéricos en tiempo de ejecución. A diferencia de Java, donde los tipos genéricos se borran en tiempo de compilación, Kotlin permite retener información sobre estos tipos, facilitando su manipulación...

1. CRUD simple

Aquí hay un ejemplo de una aplicación Spring WebFlux en Kotlin que expone un CRUD para la entidad usuario.

data class User(val id: Long, val nombre: 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)  ...