io.reactivex.Observable#filter ( )源码实例Demo

下面列出了io.reactivex.Observable#filter ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： RxCache 文件： FirstCacheTimeoutStrategy.java

@Override
public <T> Observable<CacheResult<T>> execute(RxCache rxCache, String key, Observable<T> source, Type type) {
    Observable<CacheResult<T>> cache = RxCacheHelper.loadCache(rxCache, key, type, true);
    cache = cache.filter(new Predicate<CacheResult<T>>() {
        @Override
        public boolean test(CacheResult<T> tCacheResult) throws Exception {
            return System.currentTimeMillis() - tCacheResult.getTimestamp() <= milliSecond;
        }
    });
    Observable<CacheResult<T>> remote;
    if (isSync) {
        remote = RxCacheHelper.loadRemoteSync(rxCache, key, source, CacheTarget.MemoryAndDisk, false);
    } else {
        remote = RxCacheHelper.loadRemote(rxCache, key, source, CacheTarget.MemoryAndDisk, false);
    }
    return cache.switchIfEmpty(remote);
}

源代码2 项目： Tangram-Android 文件： LifeCycleHelper.java

public static <T, E> LifecycleTransformer<T> bindUntilEvent(Observable<E> lifecycle, final E event) {
    return new LifecycleTransformer<>(lifecycle.filter(new Predicate<E>() {
        @Override
        public boolean test(E e) throws Exception {
            return e.equals(event);
        }
    }));
}

源代码3 项目： Tangram-Android 文件： LifeCycleHelper.java

public static <T, E> LifecycleTransformer<T> bindUntilEvent(Observable<E> lifecycle, final E event) {
    return new LifecycleTransformer<>(lifecycle.filter(new io.reactivex.functions.Predicate<E>() {
        @Override
        public boolean test(E e) throws Exception {
            return e.equals(event);
        }
    }));
}

源代码4 项目： Tangram-Android 文件： LifeCycleHelper.java

public static <T, E> LifecycleTransformer<T> bindUntilEvent(Observable<E> lifecycle, final E event) {
    return new LifecycleTransformer<>(lifecycle.filter(new io.reactivex.functions.Predicate<E>() {
        @Override
        public boolean test(E e) throws Exception {
            return e.equals(event);
        }
    }));
}

源代码5 项目： moVirt 文件： AccountRxStore.java

public Observable<MovirtAccount> onRemovedAccountObservable(MovirtAccount account) {
    Observable<MovirtAccount> result = REMOVED_ACCOUNT;

    if (!environmentStore.hasEnvironment(account)) {
        result = result.startWith(account);
    }

    return result.filter(acc -> acc.equals(account));
}