Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
Supply.categorize: distribute .done to sub-supplies
  • Loading branch information
moritz committed Jan 25, 2015
1 parent 0c524e3 commit 94501a6
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/core/SupplyOperations.pm
Expand Up @@ -361,6 +361,11 @@ my class SupplyOperations is repr('Uninstantiable') {
};
}

method !classify-done() {
%!mapping.values>>.done;
self!done;
}

method live { $source.live }
method tap(|c) {
my $source_tap;
Expand All @@ -374,7 +379,7 @@ my class SupplyOperations is repr('Uninstantiable') {
!! -> \val {
self.find_supply( mapper(val) ).emit(val);
},
done => { self!done(); },
done => { self!classify-done(); },
quit => -> $ex { self!quit($ex) });
$tap
}
Expand Down

0 comments on commit 94501a6

Please sign in to comment.