use Future.empty in Future.channel
This commit is contained in:
parent
6e45ab7c17
commit
33f05856c1
1 changed files with 1 additions and 1 deletions
|
|
@ -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
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue