From 290f508195ad7934a32a8f8586b96d315e4dbe80 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Thu, 19 Jan 2012 17:47:58 +0100 Subject: [PATCH] Modifying the test for Futures.reduce --- akka-docs/java/code/akka/docs/future/FutureDocTestBase.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-docs/java/code/akka/docs/future/FutureDocTestBase.java b/akka-docs/java/code/akka/docs/future/FutureDocTestBase.java index c3278f23bd..1e4e7fd350 100644 --- a/akka-docs/java/code/akka/docs/future/FutureDocTestBase.java +++ b/akka-docs/java/code/akka/docs/future/FutureDocTestBase.java @@ -267,13 +267,13 @@ public class FutureDocTestBase { //A sequence of Futures, in this case Strings Iterable> futures = source; - Future resultFuture = reduce(futures, new Function2() { - public String apply(String r, String t) { + Future resultFuture = reduce(futures, new Function2() { + public Object apply(Object r, String t) { return r + t; //Just concatenate } }, system.dispatcher()); - String result = Await.result(resultFuture, Duration.create(1, SECONDS)); + Object result = Await.result(resultFuture, Duration.create(1, SECONDS)); //#reduce assertEquals("ab", result);