使用泛型和rxjava的不兼容类型

Question

偶然发现不兼容的类型错误原因我不明白。

错误：不兼容的类型：Flowable无法转换为Flowable，其中T是一个类型变量：T扩展方法getPackets（Class）中声明的数据包

为什么这段代码错了？

public Flowable<Packet> getPackets() {
        .....}public <T extends Packet> Flowable<T> getPackets(Class<T> type) {

    return getPackets().filter(type::isInstance);}

Flowable并且filter()是其中一部分rxjava，filter()看起来像这样：

public final Flowable<T> filter(Predicate<? super T> predicate)




Answer 1

通过使用ofType（）而不是filter（）来修复它。