view release on metacpan or  search on metacpan

lib/AnyEvent/RabbitMQ/LocalQueue.pm  view on Meta::CPAN

    return $self;
}

sub _flush {
    my ($self, $frame) = @_;

    $self->_drain_queue;

    while (my $cb = shift @{$self->{_drain_code_queue}}) {
        local $@; # Flush frames immediately, throwing away errors for on-close
        eval { $cb->($frame) };
    }
}

1;