From d286e6f95297464a5639cc854f276e2d41a538ee Mon Sep 17 00:00:00 2001
From: Felipe Gasper <felipe@felipegasper.com>
Date: Mon, 23 May 2022 11:40:13 -0400
Subject: [PATCH] retry mojo

---
 MANIFEST              |  1 +
 t/pause_resume_mojo.t | 26 +++++++++++---------------
 2 files changed, 12 insertions(+), 15 deletions(-)

diff --git a/MANIFEST b/MANIFEST
index 0d8d83f..41373a0 100644
--- a/MANIFEST
+++ b/MANIFEST
@@ -62,3 +62,4 @@ t/lib/DBusSession.pm
 t/lib/MockDBusServer.pm
 t/mojo_uncaught_failure.t
 t/pause_resume.t
+t/pause_resume_mojo.t
diff --git a/t/pause_resume_mojo.t b/t/pause_resume_mojo.t
index 6f2280d..de8599a 100644
--- a/t/pause_resume_mojo.t
+++ b/t/pause_resume_mojo.t
@@ -46,12 +46,12 @@ SKIP: {
 
             $bus_name = $messenger->get_unique_bus_name();
 
-            return Promise::ES6->new( sub {
+            return Mojo::Promise->new( sub {
                 my ($y, $n) = @_;
 
-                my $timer = AnyEvent->timer(
-                    after => 5,
-                    cb => sub {
+                my $timer_id = Mojo::IOLoop->timer(
+                    5,
+                    sub {
                         $n->('timed out');
                     },
                 );
@@ -106,12 +106,9 @@ SKIP: {
             return Promise::ES6->new( sub {
                 my ($y, $n) = @_;
 
-                my $timer;
-                $timer = AnyEvent->timer(
-                    after => 1,
+                my $timer_id = Mojo::IOLoop->timer(
+                    1,
                     cb => sub {
-                        undef $timer;
-
                         is(
                             "@received_while_paused",
                             q<>,
@@ -132,10 +129,10 @@ SKIP: {
             return Promise::ES6->new( sub {
                 my ($y, $n) = @_;
 
-                my $timer;
+                my $timer_id;
 
                 $on_signal_cr = sub {
-                    undef $timer;
+                    Mojo::IOLoop->remove($timer_id);
                     push @received_after_resume, shift;
                     $y->();
                 };
@@ -144,10 +141,9 @@ SKIP: {
                 $messenger->resume();
                 diag 'resumed';
 
-                $timer = AnyEvent->timer(
-                    after => 10,
-                    cb => sub {
-                        undef $timer;
+                $timer_id = Mojo::IOLoop->timer(
+                    5,
+                    sub {
                         $n->('timeout waiting for D-Bus signal!');
                     },
                 );