| ZeroMQ::Poller(3pm) - phpMan
ZeroMQ::Poller(3pm) User Contributed Perl Documentation ZeroMQ::Poller(3pm)
NAME
ZeroMQ::Poller - Convenient socket polling object
SYNOPSIS
use ZeroMQ qw/:all/;
my $cxt = ZeroMQ::Context->new()
my $sock = ZeroMQ::Socket->new($cxt, ZMQ_REP);
$sock->bind("inproc://amazingsocket");
my $poller = ZeroMQ::Poller->new(
{
name => 'amazing',
socket => $sock,
events => ZMQ_POLLIN,
callback => sub { do_something_amazing },
},
);
$poller->poll();
do_another_amazing_thing() if $poller->has_event(0);
do_a_third_amazing_thing() if $poller->has_event('amazing');
DESCRIPTION
A "ZeroMQ::Poller" watches zero or more sockets for events and signals that these have
occurred in several ways. Given a list of sockets and events to watch for, it can
directly invoke a callback or simply raise a flag.
METHODS
new(@poll_items)
Creates a new "ZeroMQ::Poller"
The constructor accepts a list of hash references ("poll items"), each of which specifies
a socket or file descriptor to watch and what to watch it for. In addition, each poll
item may specify a callback to invoke or a name by which it may be queried. The accepted
keys are:
socket
Contains the "ZeroMQ::Socket" item to poll.
fd Contains the file descriptor to poll. One of "socket" or "fd" is required; "socket"
has precedence.
events
Some combination of "ZMQ_POLLIN", "ZMQ_POLLOUT", and "ZMQ_POLLERR"; the events to
trap.
callback
A coderef taking no arguments and emitting no return value, invoked when the specified
events occur on the socket or file descriptor. Optional.
name
A string, naming the poll item for later use with "has_event".
poll($timeout)
Blocks until there is activity or the given timeout is reached. If no timeout or a
negative timeout is specified, blocks indefinitely. If a timeout is given, it is
interpreted as microseconds.
has_event($index)
has_event($name)
Returns true if the poll item at the given index or with the given name reported activity
during the last call to "poll".
perl v5.20.0 2012-10-16 ZeroMQ::Poller(3pm)
|