RXJava：忽略“single.subscribe（）”的结果

Question

我正在学习RXJava的基础知识。正如您所看到的，我有一个小方法，它只检查两个整数是否相等，并以单个的形式返回结果

/**
 * This method checks if both online and offline shopping carts have the same number of items
 * @param numberOfItemsInLocalCart The number of items existing in the offline cart
 * @return true if items in both carts match, false otherwise
 */
public static Single<Boolean> run(int numberOfItemsInLocalCart)
{
    return Single.create(emitter ->
            _VolleyService.getInstance().getDataFuture(URLs.Home).subscribe(
                response ->
                {
                    ShoppingCart cart = HTMLParser.getItemsInShoppingCart(response);
                    if(cart.NumberOfElements == numberOfItemsInLocalCart)
                        emitter.onSuccess(true);
                    else
                        emitter.onSuccess(false);
                },
                    emitter::onError));
}

我收到一条警告消息,显示：

Result of 'Single.subscribe()' is ignored

我怎样才能以一种适当的方式摆脱这个？

Answer 1

single#subscribe返回disposable。保留对此的引用允许您在以后取消订阅single的结果。

var disposable: Disposable? = run(20).subscribe()
//And later, if you're no longer interested in the result of your Single...
disposable?.dispose()