view release on metacpan or  search on metacpan

README.md  view on Meta::CPAN

AnyEvent::PgRecvlogical
=======================

[![Build Status](https://travis-ci.org/mydimension/AnyEvent-PgRecvlogical.svg?branch=master)](https://travis-ci.org/mydimension/AnyEvent-PgRecvlogical)
[![Coverage Status](https://coveralls.io/repos/github/mydimension/AnyEvent-PgRecvlogical/badge.svg?branch=master)](https://coveralls.io/github/mydimension/AnyEvent-PgRecvlogical?branch=master)
[![CPAN version](https://badge.fury.io/pl/AnyEvent-PgRecvlogical.svg)](https://badge.fury.io/pl/AnyEvent-PgRecvlogical)

`AnyEvent::PgRecvlogical` provides perl bindings of similar functionality to that of
[`pg_recvlogical`](https://www.postgresql.org/docs/current/static/app-pgrecvlogical.html).
The reasoning being that `pg_recvlogical` does afford the consuming process the opportunity to emit feedback to
PostgreSQL. This results is potentially being sent more data than you can handle in a timely fashion.

Copyright
=========

Copyright (c) 2107-2018 William Cox

License

lib/AnyEvent/PgRecvlogical.pm  view on Meta::CPAN

            process($record);

            undef $guard; # declare done with $record
        }
    );

    $recv->start;

=head1 DESCRIPTION

C<AnyEvent::PgRecvlogical> provides perl bindings of similar functionality to that of
L<pg_recvlogical|https://www.postgresql.org/docs/current/static/app-pgrecvlogical.html>.
The reasoning being that C<pg_recvlogical> does afford the consuming process the opportunity to emit feedback to
PostgreSQL. This results is potentially being sent more data than you can handle in a timely fashion.

=cut

use Moo;
use DBI;
use DBD::Pg 3.7.0 ':async';
use AnyEvent;