From c87ab663b4cf7e199b9f4733009525032413d6a9 Mon Sep 17 00:00:00 2001 From: "fabio.simeoni" Date: Tue, 18 Sep 2012 10:15:12 +0000 Subject: [PATCH] improved portability of async code tests by reducing dependencies on time git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/branches/common/common-clients/2.0@58635 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../java/org/gcube/common/clients/AsyncDelegateTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/test/java/org/gcube/common/clients/AsyncDelegateTest.java b/src/test/java/org/gcube/common/clients/AsyncDelegateTest.java index 861dcbb..288bbf6 100644 --- a/src/test/java/org/gcube/common/clients/AsyncDelegateTest.java +++ b/src/test/java/org/gcube/common/clients/AsyncDelegateTest.java @@ -191,7 +191,7 @@ public class AsyncDelegateTest { Future future = delegate.makeAsync(call,callback); //make sure we test after call has been delivered - latch.await(1, SECONDS); + latch.await(5, SECONDS); verify(callback).done(value); @@ -217,8 +217,6 @@ public class AsyncDelegateTest { Callback callback = mock(Callback.class); when(callback.timeout()).thenReturn(50L); - Future future = delegate.makeAsync(call,callback); - final CountDownLatch latch = new CountDownLatch(1); Answer unblock = new Answer() { @@ -230,9 +228,11 @@ public class AsyncDelegateTest { }; doAnswer(unblock).when(callback).onFailure(any(TimeoutException.class)); + + Future future = delegate.makeAsync(call,callback); //makes sure callback has been invoked - latch.await(1,SECONDS); + latch.await(5,SECONDS); assertTrue(future.isCancelled()); }