abstract class AbstractCloseAwaitably extends AbstractClosable with Awaitable[BoxedUnit]
Java's analog of Scala's com.twitter.util.CloseAwaitably.
In order to make it more Java-friendly, the abstract method
com.twitter.util.AbstractCloseAwaitably#onClose is used instead of a higher-order
function in Scala version.
An example usage looks as follows.
class A extends AbstractCloseAwaitably {
public Future onClose(Time deadline) {
return Future.Done();
}
}
- Alphabetic
- By Inheritance
- AbstractCloseAwaitably
- Awaitable
- AbstractClosable
- Closable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new AbstractCloseAwaitably()
Abstract Value Members
- abstract def isReady(implicit permit: CanAwait): Boolean
Is this Awaitable ready? In other words: would calling Awaitable.ready block?
Is this Awaitable ready? In other words: would calling Awaitable.ready block?
- Definition Classes
- Awaitable
- abstract def onClose(deadline: Time): Future[BoxedUnit]
An on-close handler that is executed when this
com.twitter.util.Closableis being closed. - abstract def ready(timeout: Duration)(implicit permit: CanAwait): AbstractCloseAwaitably.this.type
Support for
Await.ready.Support for
Await.ready. The use of the implicit permit is an access control mechanism: onlyAwait.readymay call this method.- Definition Classes
- Awaitable
- Annotations
- @throws(classOf[TimeoutException]) @throws(classOf[InterruptedException])
- abstract def result(timeout: Duration)(implicit permit: CanAwait): BoxedUnit
Support for
Await.result.Support for
Await.result. The use of the implicit permit is an access control mechanism: onlyAwait.resultmay call this method.- Definition Classes
- Awaitable
- Annotations
- @throws(classOf[Exception])
Concrete 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def close(deadline: Time): Future[BoxedUnit]
- Definition Classes
- AbstractCloseAwaitably → Closable
- Annotations
- @Override()
- See also
com.twitter.util.Closable#close()
- def close(after: Duration): Future[Unit]
Close the resource with the given timeout.
Close the resource with the given timeout. This timeout is advisory, giving the callee some leeway, for example to drain clients or finish up other tasks.
- Definition Classes
- Closable
- final def close(): Future[Unit]
Close the resource.
Close the resource. The returned Future is completed when the resource has been fully relinquished.
- Definition Classes
- Closable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isReady(permit: CanAwait): Boolean
- Annotations
- @Override()
- See also
com.twitter.util.Awaitable#isReady(com.twitter.util.Awaitable.CanAwait)
- 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 ready(timeout: Duration, permit: CanAwait): Awaitable[BoxedUnit]
- Annotations
- @Override()
- See also
com.twitter.util.Awaitable#ready(Duration, com.twitter.util.Awaitable.CanAwait)
- def result(timeout: Duration, permit: CanAwait): BoxedUnit
- Annotations
- @Override()
- See also
com.twitter.util.Awaitable#result(Duration, com.twitter.util.Awaitable.CanAwait)
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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
- @throws(classOf[java.lang.InterruptedException]) @native()