Increasing timeouts for FutureDocTestBase to avoid Jenkins being too slow.
This commit is contained in:
parent
f5895ba64c
commit
3a0cf84d2c
1 changed files with 15 additions and 15 deletions
|
|
@ -113,7 +113,7 @@ public class FutureDocTestBase {
|
||||||
return "Hello" + "World";
|
return "Hello" + "World";
|
||||||
}
|
}
|
||||||
}, system.dispatcher());
|
}, system.dispatcher());
|
||||||
String result = (String) Await.result(f, Duration.create(1, SECONDS));
|
String result = (String) Await.result(f, Duration.create(5, SECONDS));
|
||||||
//#future-eval
|
//#future-eval
|
||||||
assertEquals("HelloWorld", result);
|
assertEquals("HelloWorld", result);
|
||||||
}
|
}
|
||||||
|
|
@ -135,7 +135,7 @@ public class FutureDocTestBase {
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
int result = Await.result(f2, Duration.create(1, SECONDS));
|
int result = Await.result(f2, Duration.create(5, SECONDS));
|
||||||
assertEquals(10, result);
|
assertEquals(10, result);
|
||||||
//#map
|
//#map
|
||||||
}
|
}
|
||||||
|
|
@ -159,7 +159,7 @@ public class FutureDocTestBase {
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
//#map2
|
//#map2
|
||||||
int result = Await.result(f2, Duration.create(1, SECONDS));
|
int result = Await.result(f2, Duration.create(5, SECONDS));
|
||||||
assertEquals(10, result);
|
assertEquals(10, result);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -183,7 +183,7 @@ public class FutureDocTestBase {
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
//#map3
|
//#map3
|
||||||
int result = Await.result(f2, Duration.create(1, SECONDS));
|
int result = Await.result(f2, Duration.create(5, SECONDS));
|
||||||
assertEquals(10, result);
|
assertEquals(10, result);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -209,7 +209,7 @@ public class FutureDocTestBase {
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
//#flat-map
|
//#flat-map
|
||||||
int result = Await.result(f2, Duration.create(1, SECONDS));
|
int result = Await.result(f2, Duration.create(5, SECONDS));
|
||||||
assertEquals(10, result);
|
assertEquals(10, result);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -238,7 +238,7 @@ public class FutureDocTestBase {
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
long result = Await.result(futureSum, Duration.create(1, SECONDS));
|
long result = Await.result(futureSum, Duration.create(5, SECONDS));
|
||||||
//#sequence
|
//#sequence
|
||||||
assertEquals(3L, result);
|
assertEquals(3L, result);
|
||||||
}
|
}
|
||||||
|
|
@ -262,7 +262,7 @@ public class FutureDocTestBase {
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
//Returns the sequence of strings as upper case
|
//Returns the sequence of strings as upper case
|
||||||
Iterable<String> result = Await.result(futureResult, Duration.create(1, SECONDS));
|
Iterable<String> result = Await.result(futureResult, Duration.create(5, SECONDS));
|
||||||
assertEquals(Arrays.asList("A", "B", "C"), result);
|
assertEquals(Arrays.asList("A", "B", "C"), result);
|
||||||
//#traverse
|
//#traverse
|
||||||
}
|
}
|
||||||
|
|
@ -286,7 +286,7 @@ public class FutureDocTestBase {
|
||||||
return r + t; //Just concatenate
|
return r + t; //Just concatenate
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
String result = Await.result(resultFuture, Duration.create(1, SECONDS));
|
String result = Await.result(resultFuture, Duration.create(5, SECONDS));
|
||||||
//#fold
|
//#fold
|
||||||
|
|
||||||
assertEquals("ab", result);
|
assertEquals("ab", result);
|
||||||
|
|
@ -310,7 +310,7 @@ public class FutureDocTestBase {
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
Object result = Await.result(resultFuture, Duration.create(1, SECONDS));
|
Object result = Await.result(resultFuture, Duration.create(5, SECONDS));
|
||||||
//#reduce
|
//#reduce
|
||||||
|
|
||||||
assertEquals("ab", result);
|
assertEquals("ab", result);
|
||||||
|
|
@ -326,10 +326,10 @@ public class FutureDocTestBase {
|
||||||
Future<String> otherFuture = Futures.failed(
|
Future<String> otherFuture = Futures.failed(
|
||||||
new IllegalArgumentException("Bang!"));
|
new IllegalArgumentException("Bang!"));
|
||||||
//#failed
|
//#failed
|
||||||
Object result = Await.result(future, Duration.create(1, SECONDS));
|
Object result = Await.result(future, Duration.create(5, SECONDS));
|
||||||
assertEquals("Yay!", result);
|
assertEquals("Yay!", result);
|
||||||
Throwable result2 = Await.result(otherFuture.failed(),
|
Throwable result2 = Await.result(otherFuture.failed(),
|
||||||
Duration.create(1, SECONDS));
|
Duration.create(5, SECONDS));
|
||||||
assertEquals("Bang!", result2.getMessage());
|
assertEquals("Bang!", result2.getMessage());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -399,7 +399,7 @@ public class FutureDocTestBase {
|
||||||
throw problem;
|
throw problem;
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
int result = Await.result(future, Duration.create(1, SECONDS));
|
int result = Await.result(future, Duration.create(5, SECONDS));
|
||||||
assertEquals(result, 0);
|
assertEquals(result, 0);
|
||||||
//#recover
|
//#recover
|
||||||
}
|
}
|
||||||
|
|
@ -425,7 +425,7 @@ public class FutureDocTestBase {
|
||||||
throw problem;
|
throw problem;
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
int result = Await.result(future, Duration.create(1, SECONDS));
|
int result = Await.result(future, Duration.create(5, SECONDS));
|
||||||
assertEquals(result, 0);
|
assertEquals(result, 0);
|
||||||
//#try-recover
|
//#try-recover
|
||||||
}
|
}
|
||||||
|
|
@ -497,7 +497,7 @@ public class FutureDocTestBase {
|
||||||
}
|
}
|
||||||
}, ec);
|
}, ec);
|
||||||
|
|
||||||
String result = Await.result(future3, Duration.create(1, SECONDS));
|
String result = Await.result(future3, Duration.create(5, SECONDS));
|
||||||
assertEquals("foo bar", result);
|
assertEquals("foo bar", result);
|
||||||
//#zip
|
//#zip
|
||||||
}
|
}
|
||||||
|
|
@ -509,7 +509,7 @@ public class FutureDocTestBase {
|
||||||
Future<String> future3 = Futures.successful("bar");
|
Future<String> future3 = Futures.successful("bar");
|
||||||
// Will have "bar" in this case
|
// Will have "bar" in this case
|
||||||
Future<String> future4 = future1.fallbackTo(future2).fallbackTo(future3);
|
Future<String> future4 = future1.fallbackTo(future2).fallbackTo(future3);
|
||||||
String result = Await.result(future4, Duration.create(1, SECONDS));
|
String result = Await.result(future4, Duration.create(5, SECONDS));
|
||||||
assertEquals("bar", result);
|
assertEquals("bar", result);
|
||||||
//#fallback-to
|
//#fallback-to
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue