raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge branch 'master' of github.com:jboner/akka

Browse source
This commit is contained in:
Jonas Bonér 2011-04-23 11:57:20 +02:00
commit a2da2bfa02
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-actor/src/main/scala/akka/dispatch/Future.scala
View file

@ -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