RxJava - Tạo có thể quan sát

Sau đây là các lớp cơ sở để tạo ra các có thể quan sát.

• Flowable- 0..N luồng, phát ra 0 hoặc n mục. Hỗ trợ dòng phản ứng và áp lực ngược.

• Observable - 0..N chảy, nhưng không có áp suất ngược.

• Single- 1 mục hoặc lỗi. Có thể được coi như một phiên bản phản ứng của cuộc gọi phương thức.

• Completable- Không có mục phát ra. Được sử dụng như một tín hiệu để hoàn thành hoặc lỗi. Có thể được coi như một phiên bản phản ứng của Runnable.

• MayBe- Không có mục nào hoặc phát ra 1 mục. Có thể được coi là phiên bản phản ứng của Tùy chọn.

Sau đây là các phương pháp thuận tiện để tạo các có thể quan sát trong lớp Quan sát được.

• just(T item) - Trả về một Observable báo hiệu mục đã cho (tham chiếu không đổi) và sau đó hoàn thành.

• fromIterable(Iterable source) - Chuyển đổi một chuỗi lặp có thể lặp lại thành một nguồn quan sát có thể phát ra các mục trong chuỗi.

• fromArray(T... items) - Chuyển đổi một Mảng thành một nguồn quan sát có thể phát ra các mục trong Mảng.

• fromCallable(Callable supplier) - Trả về một Observable mà khi một người quan sát đăng ký vào nó, sẽ gọi một hàm mà bạn chỉ định và sau đó phát ra giá trị được trả về từ hàm đó.

• fromFuture(Future future) - Chuyển đổi Tương lai thành Nguồn quan sát.

• interval(long initialDelay, long period, TimeUnit unit) - Trả về một Observable phát ra 0L sau thời gian ban đầu và các số tăng dần sau mỗi khoảng thời gian sau đó.