File Coverage

blib/lib/POE/Component/Rendezvous/Publish.pm

Criterion	Covered	Total	%
statement	15	39	38.4
branch	0	6	0.0
condition			n/a
subroutine	5	10	50.0
pod	0	3	0.0
total	20	58	34.4

package POE::Component::Rendezvous::Publish;

use strict;
use warnings;

our $VERSION = '0.01';

use Net::Rendezvous::Publish;
use POE;
use POE::Session;


sub create {
  my $class = shift;

  my $publisher = Net::Rendezvous::Publish->new;
  return undef unless $publisher;

  my $self = bless { publisher => $publisher, services => {} }, $class;
  $self->add_service( @_ );

  POE::Session->create(
      object_states => [
        $self => {
          _start => '_start_event',
          step   => '_step_event',
        },
      ],
  );
}


sub _start_event {
  my $self = $_[OBJECT];
  my $kern = $_[KERNEL];

  $kern->delay_set( step => 2 );
}


sub _step_event {
  my $self = $_[OBJECT];
  my $kern = $_[KERNEL];

  $kern->delay_set( step => 2 );
  $self->step();
}


sub step {
  my $self = shift;
  my $pub  = $self->{publisher};

  $pub->step( 0.01 );
}


sub add_service {
  my $self = shift;
  my $pub  = $self->{publisher};
  my %args = @_;

  return 0 unless $args{name};

  my $service = $pub->publish( %args );
  return 0 unless $service;

  $self->{$args{name}} = $service;
  return 1;
}


1;
__END__