NAME

Net::Async::ZMQ - IO::Async support for ZeroMQ

VERSION

version 0.002

SYNOPSIS

  use IO::Async::Loop;
  use Net::Async::ZMQ;
  use Net::Async::ZMQ::Socket;

  use ZMQ::LibZMQ3;  # or ZMQ::LibZMQ4
  use ZMQ::Constants qw(
    ZMQ_REQ
    ZMQ_NOBLOCK
    ZMQ_EVENTS ZMQ_POLLIN
  );

  my $loop = IO::Async::Loop->new;

  my $ctx = zmq_init();
  my $client_socket = zmq_socket( $ctx, ZMQ_REQ );
  zmq_connect( $client_socket, "tcp://127.0.0.1:9999" );

  my $counter = 0;

  my $zmq = Net::Async::ZMQ->new;

  zmq_sendmsg( $client_socket, "initial message" );

  $zmq->add_child(
    Net::Async::ZMQ::Socket->new(
      socket => $client_socket,
      on_read_ready => sub {
        while ( zmq_getsockopt( $client_socket, ZMQ_EVENTS ) & ZMQ_POLLIN ) {
          my $recvmsg = zmq_recvmsg( $client_socket, ZMQ_NOBLOCK );
          my $msg = zmq_msg_data($recvmsg);
          zmq_sendmsg( $client_socket, "hello @{[ $counter++ ]}" );
        }
      },
    )
  );

  $loop->add( $zmq );

  $loop->run;

DESCRIPTION

A subclass of IO::Async::Notifier that can hold ZMQ sockets that are provided by Net::Async::ZMQ::Socket.

Supports sockets from the following libraries:

• ZMQ::LibZMQ3

• ZMQ::LibZMQ4

• ZMQ::FFI

EXTENDS

• IO::Async::Notifier

SEE ALSO

• ZMQ_FD in zmq_getsockopt

• ZeroMQ - Edge Triggered Notification

AUTHOR

Zakariyya Mughal <zmughal@cpan.org>

COPYRIGHT AND LICENSE

This software is copyright (c) 2017 by Zakariyya Mughal.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.