trait BodyReader extends AnyRef
Representation of a HTTP message body
- Source
- BodyReader.scala
- Note
The release of resources must be idempotent, meaning that
discard()may be called after complete consumption of the body and it may also be called numerous times.
- Alphabetic
- By Inheritance
- BodyReader
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract 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() - abstract def discard(): Unit
Throw away this BodyReader
- abstract 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.
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
- 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.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- 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
- 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()