Rx trong Kotlin (P1)

Kotlin đã trở thành một ngôn ngữ được Google khuyên nên dùng khi lập trình ứng dụng Android, là ngôn ngữ tuyệt vời để thay thế cho Java, hoạt động tốt trên Android, không có ; và cuối cùng thì nó được tạo ra bởi JetBrains! :metal_tone2: Vậy với Kotlin, Rx được dùng thế nào? Bài viết này mình hy vọng sẽ giới thiệu được một phần nhỏ về cách dùng Rx trong Kotlin. Trước tiên ta sẽ tìm hiểu một chút về Rx Vậy Rx là gì? Nó là reactive programming. Reactive programming nói một cách dễ hiểu là một kiểu lập trình gắn liền với mô hình Observer, trong đó Subscribers phản ứng lại với các sự kiện được phát ra từ Observables Nhìn vào diagram này, Observables "phát" dữ liệu ra cho các Subscribers, và dù có bao nhiêu Subscribers cũng có thể lắng nghe dữ liệu từ Observables Rx cũng là Functional Programming, đo đó nó thường được gọi là Functional Reactive Programming. Khi những Subscribers nhận dữ liệu, chúng có thể áp dụng các transformations lên dữ liệu nhận được, tương tự như ta có thể làm vớt Streams trong Java 8. Bạn có thể nhìn vào diagram này: Rx cũng rất flexible khi bạn có thể merge các luồng với nhau, vì vậy điều rút ra được là chúng ta có thể làm rất nhiều thứ hay ho với dữ liệu mà Subscribers nhận được từ Observables, và tất nhiên là ngay lập tức.