Khi nào cần hủy đăng ký thuê bao

Question

Tôi có câu hỏi liên quan đến cách hủy đăng ký một quan sát. Tôi có hai mã và tôi không thực sự chắc chắn về mã nào tốt hơn.

Ví dụ 1 -> Hủy đăng ký thuê bao một khi dòng đã hoàn tất:

Subscriber<String> subscriber = new Subscriber<String>() { 
     @Override 
     public void onCompleted() { 
      progressdialog.dissmiss(); 
      unsubscribe(); 
     } 

     @Override 
     public void onError(Throwable e) { 
      progressdialog.dissmiss(); 
     } 

     @Override 
     public void onNext(String s) { 
      // do something with data 
     } 
    } 

Ví dụ 2 -> Hủy đăng ký thuê bao một lần hoạt động này bị phá hủy:

private void test(){ 
    Subscriber<String> subscriber = new Subscriber<String>() { 
     @Override 
     public void onCompleted() { 
      progressdialog.dissmiss(); 
     } 

     @Override 
     public void onError(Throwable e) { 
      progressdialog.dissmiss(); 
     } 

     @Override 
     public void onNext(String s) { 
      // do something with data 
     } 
    }; 

    subscription = BackendRequest.login(loginRequest) 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(subscriber); 

    compositeSubscription.add(subscription); 
} 

@Override 
protected void onDestroy() { 
    super.onDestroy(); 
    this.subscription.unsubscribe(); 
} 

tôi phải đề cập đến rằng tôi chỉ quan sát được sẽ phát ra một lần, hoạt động không nên đợi nhiều cuộc gọi hơn từ Đài quan sát.

Cái nào tốt hơn?

Cảm ơn trước

Answer 1

Từ hai tùy chọn, tùy chọn thứ hai tốt hơn.

Trong ví dụ đầu tiên của bạn, bạn là unsubscribing trong phương pháp onComplete() không cần thiết. Nếu bạn đạt đến số onComplete() của Đăng ký, bạn không còn phải chịu trách nhiệm hủy đăng ký nữa.

Ví dụ thứ hai của bạn là ví dụ chính xác. Ý tưởng đằng sau CompositeSubscription là bạn có thể thêm nhiều Subscriptions vào nó và sau đó làm sạch (unsubscribe) cùng một lúc. Nói cách khác, điều này chỉ giúp bạn tiết kiệm được sự cần thiết phải giữ một danh sách Subscriptions mà bạn cần phải hủy đăng ký.

Một phần khó khăn khi sử dụng CompositeSubscription là nếu bạn một lần unsubscribe, bạn có thể NOT sử dụng lại. Bạn có thể kiểm tra tài liệu cho phương thức compositeSubscription.add() để biết chi tiết lý do. Tóm lại - nó sẽ trực tiếp hủy đăng ký Đăng ký bạn đang cố gắng thêm. Đó là một quyết định có chủ ý (bạn có thể đọc thêm về nó HERE).

Quay lại ví dụ của bạn, gọi unsubscribe() trong onDestroy() hoạt động là tốt và sẽ giúp bạn tiết kiệm từ rò rỉ bộ nhớ. Về nhận xét của bạn rằng các vấn đề xảy ra khi bạn gọi phương thức test() nhiều lần - tôi muốn nói vấn đề của bạn là ở một nơi khác. Có thể trường hợp sử dụng của bạn không được phép gọi nhiều lần, có thể bạn nên dọn dẹp dữ liệu cũ trước khi sử dụng dữ liệu mới nhận được, v.v. Có lẽ nếu bạn đã giải thích chi tiết về loại vấn đề bạn gặp phải, chúng tôi có thể trợ giúp nhiều hơn. Nhưng theo như các CompositeSubscription là có liên quan - bạn đang sử dụng nó và hủy đăng ký nó một cách chính xác!

Answer 2

Tôi nghĩ điều đó tùy thuộc vào nhu cầu của bạn. Nếu hoạt động không chờ cho bất kỳ cuộc gọi nào khác, tôi cho rằng bạn có thể hủy đăng ký bên trong onCompleted().

tôi luôn luôn bỏ đăng ký trong onDestroy()

@Override 
protected void onDestroy() { 
    super.onDestroy(); 

    if (subscription != null) { 
     subscription.unsubscribe(); 
    } 
} 

EDIT: hãy nhìn vào http://reactivex.io/RxJava/javadoc/rx/subscriptions/CompositeSubscription.html

private CompositeSubscription mCompositeSubscription = new CompositeSubscription(); 

private void doSomething() { 
    mCompositeSubscription.add(
     AndroidObservable.bindActivity(this, Observable.just("Hello, World!")) 
     .subscribe(s -> System.out.println(s))); 
} 

@Override 
protected void onDestroy() { 
    super.onDestroy(); 
    mCompositeSubscription.unsubscribe(); 
} 

Answer 3

Không cần phải để bỏ đăng ký trong onCompleted. Hãy nhìn vào The Observable Contract

Khi một vấn đề Quan sát một onerror hoặc thông báo onComplete để quan sát của nó, điều này kết thúc đăng ký. Các quan sát viên không cần phải gửi thông báo Hủy đăng ký để kết thúc đăng ký được kết thúc theo số Có thể quan sát theo cách này.

Mặt khác, bạn chắc chắn nên hủy đăng ký trong onDestroy để tránh rò rỉ bộ nhớ.