search method

Stream<List<T>> search(
  1. Stream<String> keyword, {
  2. required dynamic by,
})

根据搜索关键字keyword流来过滤原始流this

Implementation

Stream<List<T>> search(
  Stream<String> keyword, {
  required SearchCallback<T> by,
}) {
  return Rx.combineLatest2<List<T>?, String, List<T>>(
    this,
    keyword,
    (source, keyword) {
      return source?.where((it) => by(it, keyword)).toList() ?? [];
    },
  );
}