Khác với phương thức flatMap(), phương thức map() của đối tượng Mono/Flux trong Project Reactor sẽ process item được emit, synchronously: Trong hình trên, các item xanh lá cây, vàng, xanh dương được emit bởi Publisher sẽ được phương thức map() process synchronously. Kết quả… Read More

Project Reactor với các đối tượng Mono và Flux có thể sẽ làm cho các bạn cảm thấy khó khăn khi suy nghĩ về làm sao để viết Unit Test cho các đoạn code reactive. Thật ra thì điều này sẽ giải quyết dễ dàng… Read More

Thông thường chúng ta hay viết ứng dụng Reactive chạy với main thread nhưng sẽ có những trường hợp chúng ta cần sử dụng multithread, ví dụ như sau khi nhận một item dữ liệu từ Publisher, Consumer cần process một thao tác khác với… Read More

Khác với phương thức flatMap() trong đối tượng Stream của Java hay phương thức flatMap() trong đối tượng Optional trong Java giúp chúng ta có thể thao tác với các đối tượng Stream hay Optional của những đối tượng đơn giản hơn, phương thức flatMap() của… Read More

Trong bài viết trước, mình đã giới thiệu với các bạn về Reactive Streams trong Java hiện thực Reactive Streams specification. Trong bài viết này, mình sẽ giới thiệu với các bạn một thư viện nữa cũng hiện thực Reactive Stream specification luôn: đó chính là… Read More