我有一個(gè)返回 ResultSet 的 Observable 的方法:public static Observable<ResultSet> queryAllAsObservable(Session session, String query, Object... partitionKeys) { List<ResultSetFuture> futures = sendQueries(session, query, partitionKeys); Scheduler scheduler = Schedulers.io(); List<Observable<ResultSet>> observables = Lists.transform(futures, (ResultSetFuture future) -> Observable.fromFuture(future, scheduler)); return Observable.merge(observables);}現(xiàn)在我需要?jiǎng)?chuàng)建此方法的一個(gè)版本,它返回一個(gè) Observable of Row。這是我試過(guò)的:public static Observable<Row> queryAllAsRowObservable(Session session, String query, Object... partitionKeys) { List<ResultSetFuture> futures = sendQueries(session, query, partitionKeys); Scheduler scheduler = Schedulers.io(); List<Observable<ResultSet>> observables = Lists.transform(futures, (ResultSetFuture future) -> Observable.fromFuture(future, scheduler)); return Observable.merge(observables).flatMapIterable(item -> item.one());}但是item -> item.one()被錯(cuò)誤標(biāo)記:no instance(s) of type variable(s) U exists so that Row conforms to Iterable<? extends U>
不存在類型變量 U 的實(shí)例,因此 Row 符合 Iterable<? 延伸你>
天涯盡頭無(wú)女友
2023-03-02 10:13:32
