diff --git a/akka-actor/src/main/scala/akka/dispatch/Future.scala b/akka-actor/src/main/scala/akka/dispatch/Future.scala index 0f44fb27c0..2b3fc6425d 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Future.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Future.scala @@ -242,7 +242,7 @@ 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 }