AnyEvent-PgRecvlogical
view release on metacpan or search on metacpan
- fix dependencies to move Dist::Zilla::App::Command::cover to develop phase
1.0 2018-05-12 09:49:29-04:00 America/New_York
- add pause/unpause methods to provide so flow control to end users
0.004 2018-01-28 18:49:54-05:00 America/New_York
- explicit dependency on Promises 0.99; <= 0.94 won't work
0.003 2018-01-22 15:57:18-05:00 America/New_York
- fix failing tests with bad plan when postgres not installed"
- still want to loop after server keepalives
0.002 2018-01-21 15:29:16-05:00 America/New_York
- POD typo
0.001 2018-01-21 14:56:06-05:00 America/New_York
- inital release
lib/AnyEvent/PgRecvlogical.pm view on Meta::CPAN
# uncoverable branch true
if ($n == -2) {
# error reading
# uncoverable statement
$self->on_error->('could not read COPY data: ' . $self->dbh->errstr);
}
my $type = substr $msg, 0, 1;
if ('k' eq $type) {
# server keepalive
my (undef, $lsnpos, $ts, $reply) = unpack PRIMARY_HEARTBEAT, $msg;
$self->_set_received_lsn($lsnpos) if $lsnpos > $self->received_lsn;
# only interested in the request-reply bit
# uncoverable branch true
if ($reply) {
# uncoverable statement
AE::postpone { $self->_heartbeat };
}
( run in 0.561 second using v1.01-cache-2.11-cpan-df04353d9ac )