class FutureWrapper[A] extends Processor[A] with ModelImpl[Update[A, Processor[A]]] with FutureProxy[A]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- FutureWrapper
- FutureProxy
- ModelImpl
- Processor
- ProcessorLike
- Model
- Future
- Awaitable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new FutureWrapper(name: String, peerFuture: Future[A])(implicit exec: ExecutionContext)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##(): Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def abort(): Unit
Asynchronously aborts the process.
Asynchronously aborts the process. This method returns immediately. Once the process is aborted, it will dispatch an
Abortedevent. This method may be called repeatedly, although calling it twice does not have any particular effect.- Definition Classes
- FutureWrapper → ProcessorLike
- def addListener(pf: Listener[Update[A, Processor[A]]]): pf.type
- Definition Classes
- ModelImpl → Model
- def andThen[U](pf: PartialFunction[Try[A], U])(implicit executor: ExecutionContext): Future[A]
- Definition Classes
- Future
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws(classOf[java.lang.CloneNotSupportedException])
- def collect[S](pf: PartialFunction[A, S])(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
- final def dispatch(update: Update[A, Processor[A]]): Unit
- Attributes
- protected
- Definition Classes
- ModelImpl
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def failed: Future[Throwable]
- Definition Classes
- Future
- def fallbackTo[U >: A](that: Future[U]): Future[U]
- Definition Classes
- Future
- def filter(p: (A) ⇒ Boolean)(implicit executor: ExecutionContext): Future[A]
- Definition Classes
- Future
- def finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def flatMap[S](f: (A) ⇒ Future[S])(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
- def flatten[S](implicit ev: <:<[A, Future[S]]): Future[S]
- Definition Classes
- Future
- def foreach[U](f: (A) ⇒ U)(implicit executor: ExecutionContext): Unit
- Definition Classes
- Future
- final def getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def isCompleted: Boolean
- Definition Classes
- FutureProxy → Future
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[S](f: (A) ⇒ S)(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
- def mapTo[S](implicit tag: ClassTag[S]): Future[S]
- Definition Classes
- Future
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def onComplete[U](func: (Try[A]) ⇒ U)(implicit executor: ExecutionContext): Unit
- Definition Classes
- FutureProxy → Future
- val peerFuture: Future[A]
- Attributes
- protected
- Definition Classes
- FutureWrapper → FutureProxy
- def progress: Double
Queries the correct progress which is value between 0.0 and 1.0
Queries the correct progress which is value between 0.0 and 1.0
- Definition Classes
- FutureWrapper → ProcessorLike
- def ready(atMost: Duration)(implicit permit: CanAwait): FutureWrapper.this.type
- Definition Classes
- FutureProxy → Awaitable
- def recover[U >: A](pf: PartialFunction[Throwable, U])(implicit executor: ExecutionContext): Future[U]
- Definition Classes
- Future
- def recoverWith[U >: A](pf: PartialFunction[Throwable, Future[U]])(implicit executor: ExecutionContext): Future[U]
- Definition Classes
- Future
- def releaseListeners(): Unit
- Attributes
- protected
- Definition Classes
- ModelImpl
- def removeListener(pf: Listener[Update[A, Processor[A]]]): Unit
- Definition Classes
- ModelImpl → Model
- def result(atMost: Duration)(implicit permit: CanAwait): A
- Definition Classes
- FutureProxy → Awaitable
- def startListening(): Unit
- Attributes
- protected
- Definition Classes
- ModelImpl
- def stopListening(): Unit
- Attributes
- protected
- Definition Classes
- ModelImpl
- final def synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- FutureWrapper → AnyRef → Any
- def transform[B](f: (Try[A]) ⇒ Try[B])(implicit executor: ExecutionContext): Future[B]
- Definition Classes
- FutureProxy → Future
- def transform[S](s: (A) ⇒ S, f: (Throwable) ⇒ Throwable)(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
- def transformWith[B](f: (Try[A]) ⇒ Future[B])(implicit executor: ExecutionContext): Future[B]
- Definition Classes
- FutureProxy → Future
- def value: Option[Try[A]]
- Definition Classes
- FutureProxy → Future
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws(classOf[java.lang.InterruptedException])
- final def withFilter(p: (A) ⇒ Boolean)(implicit executor: ExecutionContext): Future[A]
- Definition Classes
- Future
- def zip[U](that: Future[U]): Future[(A, U)]
- Definition Classes
- Future
- def zipWith[U, R](that: Future[U])(f: (A, U) ⇒ R)(implicit executor: ExecutionContext): Future[R]
- Definition Classes
- Future