diff --git a/akka-actor/src/main/scala/akka/dispatch/Future.scala b/akka-actor/src/main/scala/akka/dispatch/Future.scala index 60d956e07c..2b3fc6425d 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Future.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Future.scala @@ -242,10 +242,15 @@ object Future { * Construct a completable channel */ def channel(timeout: Long = Actor.TIMEOUT) = new Channel[Any] { - val future = new DefaultCompletableFuture[Any](timeout) + val future = empty[Any](timeout) def !(msg: Any) = future << msg } + /** + * Create an empty Future with default timeout + */ + def empty[T](timeout : Long = Actor.TIMEOUT) = new DefaultCompletableFuture[T](timeout) + import scala.collection.mutable.Builder import scala.collection.generic.CanBuildFrom