trait
PromiseStreamOut
[A]
extends AnyRef
Abstract Value Members
-
def
apply
(promise: Promise[A]): A @util.continuations.package.cps[akka.dispatch.Future[Any]]
-
def
apply
(): A @util.continuations.package.cps[akka.dispatch.Future[Any]]
-
def
dequeue
(promise: Promise[A]): Future[A]
-
def
dequeue
(): Future[A]
Concrete Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
asInstanceOf
[T0]
: T0
-
def
clone
(): AnyRef
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
def
map
[B]
(f: (A) ⇒ B)(implicit timeout: Timeout): PromiseStreamOut[B]
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any