search method
根据搜索关键字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() ?? [];
},
);
}