Filter.vala 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. namespace Invercargill.Modifiers {
  2. public class Filter<T> : Enumerable<T> {
  3. private PredicateDelegate<T> predicate_func;
  4. private Enumerable<T> input;
  5. public Filter(Enumerable<T> input, owned PredicateDelegate<T> func) {
  6. this.input = input;
  7. predicate_func = (owned)func;
  8. }
  9. public override uint? peek_count() {
  10. return null;
  11. }
  12. public override EnumerableInfo get_info() {
  13. return new EnumerableInfo.infer_single(this, EnumerableCategory.COMPUTED, input);
  14. }
  15. public override Tracker<T> get_tracker() {
  16. var tracker = input.get_tracker();
  17. return new AdvanceTracker<T>((out obj) => {
  18. while(tracker.has_next()) {
  19. var item = tracker.get_next();
  20. if(predicate_func(item)){
  21. obj = item;
  22. return true;
  23. }
  24. }
  25. obj = null;
  26. return false;
  27. });
  28. }
  29. }
  30. }