android - 如何取消订阅 RxJava 中的单个 Observable

Question

我希望在手术后取消订阅 Rx Singles。这就是我在 RxJava 中取消订阅 Observable 的方式。

public class BooksRepositoryImpl implements IBooksRepository {


    private ReplaySubject<Book> bookSubject;
    private Subscription bookSubscription;

    BooksApi BooksApi;
    ISchedulerProvider scheduler;

    @Inject
    public BooksRepositoryImpl(BooksApi BooksApi, ISchedulerProvider scheduler) {
        this.BooksApi = BooksApi;
        this.scheduler = scheduler;
    }

    @Override
    public Observable<Book> getBooks(String author) {

        if (bookSubscription == null || bookSubscription.isUnsubscribed()) {
            bookSubscription = ReplaySubject.create();

            bookSubscription = BooksApi.getBooks(author)
                    .subscribeOn(scheduler.backgroundThread());
        }

        return bookSubscription.asObservable();


    }


    @Override
    public void unbind() {

        if (bookSubscription != null && !bookSubscription.isUnsubscribed())
            bookSubscription.unsubscribe();

    }

}

但我不确定如何取消订阅 Single Observable。如果有人能够分享一些想法，那就太好了。

public class BooksRepositoryImpl implements IBooksRepository {

BooksApi BooksApi;
ISchedulerProvider scheduler;

@Inject
public BooksRepositoryImpl(BooksApi BooksApi, ISchedulerProvider scheduler) {
    this.BooksApi = BooksApi;
    this.scheduler = scheduler;
}

@Override
public Single<Book> getBooks(String author) {

    return BooksApi.getBooks(author)
            .subscribeOn(scheduler.backgroundThread());

}


@Override
public void unbind() {
    //?? HOW Can I unsubscribe here
}

Answer 1

根据文档Single ，您什么都不应该做，订阅会自行结束:

A Single will call only one of these methods, and will only call it once. Upon calling either method, the Single terminates and the subscription to it ends.

希望这对您有所帮助。对不起我的英语。