File Coverage

blib/lib/Weixin/Message/Queue.pm

Criterion	Covered	Total	%
statement	0	17	0.0
branch	0	4	0.0
condition			n/a
subroutine	0	4	0.0
pod	0	3	0.0
total	0	28	0.0

package Weixin::Message::Queue;
sub new{
    my $class  = shift;
    my $self = {
        queue               =>  [],
        callback_for_get    =>  undef,
        callback_for_get_bak   =>  undef,
    };
    return bless $self,$class;
}

sub put{
    my $self = shift;
    die "Weixin::Message::Queue->put()失败，请检查是否已经设置了队列get()回调\n"
        unless ref $self->{callback_for_get} eq 'CODE';
    push @{ $self->{queue} } ,$_[0];
    $self->_notify_to_get();
}
sub get{
    my $self = shift;
    my $cb = shift;
    die "Weixin::Message::Queue->get()仅接受一个函数引用\n" unless ref $cb eq 'CODE';
    $self->{callback_for_get} = $cb;
    $self->{callback_for_get_bak} = $cb;
}
sub _notify_to_get{
    my $self = shift;
    my $msg = shift @{$self->{queue}};
    $self->{callback_for_get}->($msg);
}

1;