Packages

abstract class Proxy extends BodyReader

Provides a simple way to proxy a BodyReader

Source
BodyReader.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Proxy
  2. BodyReader
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Proxy(underlying: BodyReader)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. 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 ByteBuffer will be empty as defined by ByteBuffer.hasRemaining()

    max

    maximum bytes to accumulate before resulting in a failed future with the exception BodyReader.BodyReaderOverflowException.

    Definition Classes
    BodyReader
  5. def apply(): Future[ByteBuffer]

    Get a Future which may contain message body data.

    Get a Future which may contain message body data.

    If no data remains, the ByteBuffer will be empty as defined by ByteBuffer.hasRemaining()

    Definition Classes
    Proxy → BodyReader
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. def discard(): Unit

    Throw away this BodyReader

    Throw away this BodyReader

    Definition Classes
    Proxy → BodyReader
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. 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 true guarantees that no more data can be obtained from this BodyReader, but a return value of false does not guarantee more data.

    Definition Classes
    Proxy → BodyReader
  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from BodyReader

Inherited from AnyRef

Inherited from Any

Ungrouped