try pinging twice in the test

revmischa · Oct 29, 2011 · c0fa069 · c0fa069
1 parent 094b548
commit c0fa069
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/t/10-pubsub.t b/t/10-pubsub.t
@@ -29,17 +29,21 @@ sub run_tests {
     my $pub_topic = $pub_bus->topic('ping');
     my $sub_topic = $sub_bus->topic('ping');
 
+    my $ping_count = 0;
     my $cv = AE::cv;
+    $cv->begin;
+    $cv->begin;
 
     # subscribe
     my $listener = $sub_bus->new_listener($sub_topic);
-    $listener->poll(sub { $cv->send });
+    $listener->poll(sub { $ping_count++; $cv->end });
 
     # publish
-    $pub_topic->publish({ __type => 'ping', __params => { bleep => 'bloop' } });
+    $pub_topic->publish({ type => 'ping', params => { bleep => 'bloop' } });
+    $pub_topic->publish({ type => 'ping', params => { bleep => 'bloop' } });
 
     $cv->recv;
-    ok("Got ping");
+    is($ping_count, 2, "Got pings");
 }