view release on metacpan or  search on metacpan

lib/AnyEvent/RabbitMQ/PubSub/Consumer.pm  view on Meta::CPAN

    my $cv = AnyEvent->condvar();
    $self->consume(
        $cv,
        sub {
            my ($consumer, $msg) = @_;

            ...
        }
    )->then(sub {
        say 'Consumer was started...';
    });


=cut

sub consume {
    my ($self, $cv, $on_consume) = @_;

    my $d = deferred();