tests for await_* with kept and thrown-away proxy object

diff --git a/t/await.t b/t/await.t
new file mode 100644 (file)
index 0000000..d96cf3d
--- /dev/null
+++ b/t/await.t
@@ -0,0 +1,63 @@
+use strictures 1;
+use Test::More;
+use Test::Fatal;
+use FindBin;
+use lib "$FindBin::Bin/lib";
+
+use Object::Remote;
+use Object::Remote::Future qw( await_all await_future );
+use ORTestClass;
+
+my $state = [];
+
+my $_make_future_keep_proxy = sub {
+  # note: do not store the remote proxy somewhere
+  my $proxy = ORTestClass->new::on('-');
+  my $future = $proxy->start::call_callback(23, sub { sleep 1 });
+  push @$state, $proxy;
+  return $future;
+};
+
+my $_make_future = sub {
+  # note: do not store the remote proxy somewhere
+  my $future = ORTestClass
+    ->new::on('-')
+    ->start::call_callback(23, sub { sleep 1 });
+};
+
+my @tests = (
+  ['proxy kept', $_make_future_keep_proxy],
+  ['proxy thrown away', $_make_future],
+);
+
+for my $test (@tests) {
+  my ($title, $make) = @$test;
+  subtest $title, sub {
+
+    do {
+      my $future = $make->();
+      local $SIG{ALRM} = sub { die "future timed out" };
+      alarm 10;
+      is exception {
+        my $result = await_future $future;
+        is $result, 23, 'correct value';
+        alarm 0;
+      }, undef, 'no errors for await_future';
+    };
+
+    do {
+      my $future = $make->();
+      local $SIG{ALRM} = sub { die "future timed out" };
+      alarm 10;
+      is exception {
+        my @result = await_all $future;
+        is $result[0], 23, 'correct value';
+        alarm 0;
+      }, undef, 'no errors for await_all';
+    };
+
+    done_testing;
+  };
+}
+
+done_testing;