+ $$buffer .= $body;
+ while ($$buffer =~ s/^\s*(.*)\n\n\n//s) {
+ handle_pgn($1, $url);
+ }
+ return 1;
+}
+
+sub end_pgn {
+ my ($body, $header, $buffer, $url) = @_;
+ handle_pgn($$buffer, $url);
+ $$buffer = "";
+ $http_timer = AnyEvent->timer(after => $remoteglotconf::poll_frequency, cb => sub {
+ fetch_pgn($url);
+ });
+}
+
+sub handle_pgn {
+ my ($body, $url) = @_;