Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
Remove the experimental "paused" functionality
  • Loading branch information
lizmat committed Jul 10, 2014
1 parent ef8137f commit 592a2ed
Showing 1 changed file with 1 addition and 13 deletions.
14 changes: 1 addition & 13 deletions src/core/Supply.pm
Expand Up @@ -18,19 +18,10 @@ my class Tap {
my role Supply {
has $!tappers_lock = Lock.new;
has @!tappers;
has $!been_tapped;
has @!paused;

method tap(Supply:D: &more = -> $ { }, :&done,:&quit={die $_},:&closing) {
my $tap = Tap.new(:&more, :&done, :&quit, :&closing, :supply(self));
$!tappers_lock.protect({
@!tappers.push($tap);
if @!paused -> \todo {
$tap.more().($_) for todo;
@!paused = ();
}
$!been_tapped = True;
});
$!tappers_lock.protect({ @!tappers.push($tap) });
$tap
}

Expand All @@ -56,9 +47,6 @@ my role Supply {
if self.tappers -> \tappers {
.more().(msg) for tappers;
}
elsif !$!been_tapped {
$!tappers_lock.protect({ @!paused.push: msg });
}
Nil;
}

Expand Down

0 comments on commit 592a2ed

Please sign in to comment.