@@ -35,7 +35,7 @@ our @C = (
$w->next;
}
},
- queue => { get => 'pushstream' },
+ continuity => 1,
),
C(
eg/Chat.pm
@@ -23,20 +23,20 @@ our @C = (
my ($self) = @_;
my $cr = $self->cr;
my $log = $self->log;
-
+
my %p = (
i => 1
);
my %callbacks;
- tie my %history, 'Tie::IxHash::FixedSize', {size => 10};
-
+ tie my %history, 'Tie::IxHash::FixedSize', {size => 10};
+
my $get_new_ci = sub {
- my $ci = -1;
- return sub {
+ my $ci = -1;
+ return sub {
$ci++ if ($ci <= ($cr->param('ci') || $ci));
return $ci;
- }
- }->();
+ }
+ }->();
$history{$get_new_ci->()} = {%p};
sub gen_link {
my ($text, $code) = @_;
@@ -48,19 +48,19 @@ our @C = (
my $cr = shift;
my $cb = $cr->param('cb');
my $ci = ($cr->param('ci') || 0);
- $log->debug($ci);
- if(defined $cb) {
+ $log->debug($ci);
+ if(defined $cb) {
if (exists $callbacks{$cb}
- && ref($callbacks{$cb}) eq "CODE") {
+ && ref($callbacks{$cb}) eq "CODE") {
$callbacks{$cb}->($cr);
delete $callbacks{$cb};
- $history{$ci} = {%p};
- } elsif (exists $history{$ci}) {
+ $history{$ci} = {%p};
+ } elsif (exists $history{$ci}) {
%p = %{$history{$ci}};
}
- }
+ }
}
-
+
while (1) {
process_links($cr);
$cr->print(gen_link('next' => sub {
@@ -74,7 +74,7 @@ our @C = (
$cr->next;
}
},
- queue => { get => 'count' }
+ continuity => 1,
)
);
eg/Counter.pm
@@ -17,15 +17,15 @@ our @C = (
Guess => [ '/guess' ],
get => sub {
my ($self) = @_;
-
+
my $cr = $self->cr;
my $rand100 = sub { int(rand(100)) };
my $to_guess = $rand100->();
my $tries = 0;
-
+
while(1) {
- my $n = $cr->param('n');
+ my $n = $cr->param('n');
$cr->print(qq|
<html>
<head>
@@ -38,11 +38,11 @@ our @C = (
if ($n) {
return "<i>The guess is invalid.</i>" if $n !~ /\d+/;
return ($n<$to_guess)
- ? "<i>The answer is higher.</i>"
+ ? "<i>The answer is higher.</i>"
: ($n>$to_guess)
? "<i>The answer is lower.</i>"
: "<i>You guessed it in $tries tries</i>";
- }
+ }
}->() . qq|
<form method="get" />
|. (($n!=$to_guess)
@@ -56,7 +56,7 @@ our @C = (
return "<a href=\"/guess\">start again</a>"
}->()
) . qq|
-
+
</form>
|);
$cr->print(qq|
@@ -64,11 +64,11 @@ our @C = (
</html>
|);
$cr->next;
-
+
$tries++;
} # while
},
- queue => { get => 'guess' }
+ continuity => 1,
),
);
eg/Guess.pm
33d626c8f6e0120906035538f5bc4f58be4f3ed6
John Beppu
john.beppu@gmail.com
http://github.com/beppu/squatting/commit/c320c96fe5b2c0555c2e6022b76eee47b3470648
c320c96fe5b2c0555c2e6022b76eee47b3470648
2009-06-14T22:02:07-07:00
2009-06-14T22:02:07-07:00
changed to new Squatting 0.70 Continuity semantics
f722ca4f4b8e6c0ad6c45ec29548b2b73b7e0ac4
John Beppu
john.beppu@gmail.com