AnyEvent-PgRecvlogical

 view release on metacpan or  search on metacpan

Changes  view on Meta::CPAN

    - 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 )