lib/Thread/Queue/Event/AnyEvent.pm


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

package Thread::Queue::Event::AnyEvent; 
use Moose::Role;
use AnyEvent;
 
requires 'event_fh';
 
sub callback {
    my ($self,$sub)=@_;
 
    AnyEvent->io(
        fh => $self->event_fh,
        poll=>'r',
        cb => $sub);
}
 
no Moose;
1;