package com.ydl.ydlnet.cache.stategy; import com.ydl.ydlnet.cache.RxCache; import com.ydl.ydlnet.cache.data.CacheResult; import io.reactivex.Flowable; import org.reactivestreams.Publisher; import java.lang.reflect.Type; /** * author : zchu * date : 2017/10/11 * desc : */ public interface IFlowableStrategy { <T> Publisher<CacheResult<T>> flow(RxCache rxCache, String key, Flowable<T> source, Type type); }