abstract class Proxy extends BodyReader
- Alphabetic
- By Inheritance
- Proxy
- BodyReader
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Proxy(underlying: BodyReader)
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 accumulate(max: Int = Int.MaxValue): Future[ByteBuffer]
Accumulate any remaining data.
Accumulate any remaining data.
The remainder of the message body will be accumulated into a single buffer. If no data remains, the
ByteBufferwill be empty as defined byByteBuffer.hasRemaining()- max
maximum bytes to accumulate before resulting in a failed future with the exception BodyReader.BodyReaderOverflowException.
- Definition Classes
- BodyReader
- def apply(): Future[ByteBuffer]
Get a
Futurewhich may contain message body data.Get a
Futurewhich may contain message body data.If no data remains, the
ByteBufferwill be empty as defined byByteBuffer.hasRemaining()- Definition Classes
- Proxy → BodyReader
- 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 discard(): Unit
Throw away this BodyReader
Throw away this BodyReader
- Definition Classes
- Proxy → BodyReader
- 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()
- def isExhausted: Boolean
Examine whether the BodyReader may yield additional data.
Examine whether the BodyReader may yield additional data.
This may be a result of being discarded, failure, or deletion of the data stream.
Because BodyReader is async it is not, in general, possible to definitively determine if more data remains in the stream. Therefore, the contract of this method is that a return value of
trueguarantees that no more data can be obtained from this BodyReader, but a return value offalsedoes not guarantee more data.- Definition Classes
- Proxy → BodyReader
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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()
- 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()