RxJava - Có thể quan sát đầy đủ

Lớp Hoàn thành đại diện cho phản hồi trì hoãn. Có thể quan sát được hoàn thành có thể cho biết hoàn thành thành công hoặc lỗi.

Khai báo lớp học

Sau đây là khai báo cho io.reactivex.Completable lớp học -

public abstract class Completable
extends Object
implements CompletableSource

Giao thức

Sau đây là giao thức tuần tự mà Completable Observable hoạt động:

onSubscribe (onError | onComplete)?

Ví dụ hoàn thành

Tạo chương trình Java sau bằng bất kỳ trình soạn thảo nào bạn chọn trong C: \> RxJava.

ObservableTester.java

import java.util.concurrent.TimeUnit;

import io.reactivex.Completable;
import io.reactivex.disposables.Disposable;
import io.reactivex.observers.DisposableCompletableObserver;
import io.reactivex.schedulers.Schedulers;

public class ObservableTester {
   public static void main(String[] args) throws InterruptedException {

      //Create an observer
      Disposable disposable = Completable.complete()
         .delay(2, TimeUnit.SECONDS, Schedulers.io())
         .subscribeWith(new DisposableCompletableObserver() {
         @Override
         public void onError(Throwable e) { 
            e.printStackTrace();
         }
         @Override
         public void onStart() {
            System.out.println("Started!");
         }
         @Override
         public void onComplete() {
            System.out.println("Done!");
         }
      }); 
      Thread.sleep(3000);
      //start observing
      disposable.dispose();
   }
}