代码之家 › 专栏 › 技术社区 › Iliya Mashin

iterable(rxJava)的.zip问题

rx-java android

Iliya Mashin · 技术社区 · 6 年前

我有四个可观察的代码。我申请 Observable.zip

Observable<Currencies> usd = CoinMarket.getMarketApi().getCurrencies();
    Observable<Currencies> rub = CoinMarket.getMarketApi().getCurrencies("RUB");
    Observable<Currencies> eur = CoinMarket.getMarketApi().getCurrencies("EUR");
    Observable<Currencies> btc = CoinMarket.getMarketApi().getCurrencies("BTC");

    List<Observable<Currencies>> singles = new ArrayList<>();
    singles.add(usd);
    singles.add(rub);
    singles.add(eur);
    singles.add(btc);

    Observable<Currencies> c = Observable.zip(singles, new Function<Currencies[], Currencies>() {
                @Override
                public Currencies apply(@NotNull Currencies[] objects) throws Exception {
                    return ramming(objects);
                }
            });

但我有个错误:

消息说找不到具有这样一个签名的方法(可能我说的不对),但是我转到声明,查看签名是否合适。

 public static <T, R> Observable<R> zip
 (Iterable<? extends ObservableSource<? extends T>> sources,
 Function<? super Object[], ? extends R> zipper)

我做错了什么?

RxJava2Iterableisbroken

2 回复 | 直到 6 年前

akarnokd 6 年前

不是虫子。你需要一个 Function<? super Object[] 由于Java的泛型限制。本文也对此进行了解释 the Javadocs of zips

Observable<Currencies> usd = CoinMarket.getMarketApi().getCurrencies();
Observable<Currencies> rub = CoinMarket.getMarketApi().getCurrencies("RUB");
Observable<Currencies> eur = CoinMarket.getMarketApi().getCurrencies("EUR");
Observable<Currencies> btc = CoinMarket.getMarketApi().getCurrencies("BTC");

List<Observable<Currencies>> singles = new ArrayList<>();
singles.add(usd);
singles.add(rub);
singles.add(eur);
singles.add(btc);

Observable<Currencies> c = Observable.zip(singles, new Function<Object[], Currencies>() {
            @Override
            public Currencies apply(@NotNull Object[] objects) throws Exception {
                Currencies[] currencies = new Currencies[objects.length];
                for (int i = 0; i < objects.length; i++) {
                     currencies[i] = (Currencies)objects[i];
                }
                return ramming(currencies);
            }
        });

karandeep singh 6 年前

推荐文章

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

6 年前

Myk Willis · 将具有指定泛型列表类型的Observable作为方法参数传递

6 年前

Mangat Rai Modi · 垂直。x反应式卡夫卡客户端:编写时链接不起作用?

6 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

6 年前

Jhon Fredy Trujillo Ortega · 如何在平面图中使用等待方法?

6 年前

casolorz · 可合成。清除导致OkHttp抛出java。lang.IllegalStateException:输入/退出不平衡

6 年前

O10 · 与observeOn组合时,RxJava启动时忽略运算符

6 年前

ddinchev · RxJava2并行执行一组completable并等待全部完成

6 年前

advice · RxJava-捕获使用者异常

6 年前

Daksh · 条件链单链和完全链

6 年前