Skip to content

Commit

Permalink
Supply.on-demand/from-list must have a Supply:U
Browse files Browse the repository at this point in the history
  • Loading branch information
lizmat committed Dec 3, 2015
1 parent d6f783b commit 09a3e3d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/core/Supply.pm
Expand Up @@ -83,7 +83,7 @@ my class Supply {
## Supply factories
##

method on-demand(&producer, :&closing, :$scheduler = CurrentThreadScheduler) {
method on-demand(Supply:U: &producer, :&closing, :$scheduler = CurrentThreadScheduler) {
Supply.new(class :: does Tappable {
has &!producer;
has &!closing;
Expand All @@ -105,7 +105,7 @@ my class Supply {
}.new(:&producer, :&closing, :$scheduler))
}

method from-list(+@values, :$scheduler = CurrentThreadScheduler) {
method from-list(Supply:U: +@values, :$scheduler = CurrentThreadScheduler) {
self.on-demand(-> $p {
$p.emit($_) for @values;
$p.done();
Expand Down

0 comments on commit 09a3e3d

Please sign in to comment.