RxJava Subscription Sınıfı

constructor
Şöyle yaparız.

Subscription subscription =  Observable.subscribe(new Subscriber<Type>() {
  @Override
  public void onCompleted() {
  }

  @Override
  public void onError(Throwable e) {
  }

  @Override
  public void onNext(String responseString) {
  }
});

isUnsubsribed metodu
Şöyle yaparız.

if(subscription!=null && !subscription.isUnsubscribed()){
      //Cancel(unSubscribe) the request if running(not completed)
      subscription.unsubscribe();
      //START A NEW REQUEST HERE
 }else{
      //already completed so START A NEW REQUEST
 }

unsubscribe

İmzası şöyle

public interface Subscription {
  void unsubscribe();
}

Örnek

Eğer kendimiz bir Observable.subscribe(Subscriber) kodluyor olsaydık şöyle yapardık

public Subscription addListener(Consumer<String> listener) {
  listeners.add(listener);
  return () -> listeners.remove(listener);
}

Daha sonra şöyle yaparız

Subscription s = subject.addListener(printListener::print);
// later on when you want to remove the listener
s.unsubscribe();