Thành phố Cuồng loạn

Giới thiệu về toán tử lọc Trong hệ sinh thái ReactiveX, việc kiểm soát dòng dữ liệu phát ra từ Observable là vô cùng quan trọng. Bài viết này sẽ đi sâu vào chi tiết cách sử dụng các toán tử giúp lược bỏ, giới hạn hoặc chọn lọc thông tin dựa trên thời gian, giá trị hoặc vị trí. Debounce và Throttle Các toán tử này hoạt động dựa trên nguyên tắc ...

Thema Trình diện ứng dụng bao gồm ba trường Nhập liệu và một Nhãn Text. Yêu cầu: Nhãn Text hiển thị tổng của ba trường Nhập liệu một cách thời gian thực. Nếu dữ liệu nhập không phải là số, coi giá trị đó là 0. Giá trị ban đầu của ba trường Nhập liệu lần lượt là 1, 2, 3. ...

Các toán tử xử lý dòng dữ liệu kết nối (connectable observables) đóng vai trò then chốt trong việc kiểm soát thời điểm phát hành và chia sẻ dữ liệu giữa nhiều người quan sát. Khác với các dòng dữ liệu thông thường, dòng kết nối cho phép tách biệt giai đoạn "chuẩn bị" và "phát hành", từ đó hỗ trợ các mô hình như phát sóng đồng thời, cache theo t ...

Kết hợp các Observable Chủ đề chính của bài viết này là các toán tử dùng để kết hợp Observable. Trong ReactiveX, Observable về cơ bản là các luồng dữ liệu có thể quan sát được. Toán tử And/Then/When Toán tử And/Then/When cho phép kết hợp hai hoặc nhiều luồng dữ liệu thông qua các thành phần trung gian là Pattern và Plan. Cách thức hoạt động ...

Các kiểu Single, Maybe và Completable là những phiên bản chuyên biệt của Observable, được thiết kế để biểu diễn các luồng dữ liệu có tính chất xác định về số lượng sự kiện thành công — cụ thể là tối đa một lần phát hành giá trị. Đặc điểm hành vi từng loại Observable<T>: Có thể phát ra 0, 1 hoặc nhiều giá trị (qua onNext), sau đó kết ...

Giới thiệu về các toán tử biến đổi Các toán tử chuyển đổi (transforming operators) trong ReactiveX cho phép thay đổi cấu trúc, nội dung hoặc tổ chức của dòng dữ liệu (Observable) mà không làm gián đoạn luồng phát hành. Chúng không lọc hay dừng luồng — thay vào đó, chúng tái cấu trúc cách dữ liệu được nhóm, ánh xạ, tích lũy hoặc phân chia thành ...

### Bộ lập lịch, đa luồng và kiểm thử Nội dung chính của bài viết tập trung vào cơ chế điều phối luồng xử lý và phương pháp kiểm thử trong ReactiveX. SubscribeOn / ObserveOn SubscribeOn và ObserveOn xác định luồng xử lý cho quá trình phát dữ liệu và quan sát dữ liệu: SubscribeOn ảnh hưởng toàn bộ quá trình từ tạo luồng đến hủy bỏ ObserveOn ...

RxPaparazzo là một thư viện mở nguồn dành cho nền tảng Android, được thiết kế để đơn giản hóa quy trình xử lý hình ảnh thông qua mô hình lập trình phản ứng (reactive programming) dựa trên RxJava. Thay vì viết hàng chục dòng mã để quản lý intent, xử lý quyền, khởi tạo activity chọn ảnh hoặc cắt ảnh, thư viện này đóng gói toàn bộ luồng công việc ...