net.sf.asyncobjects.asyncscala.nio

RichByteInput

class RichByteInput extends RichInput[ByteBuffer, Array[Byte]]

Linear Supertypes
RichInput[ByteBuffer, Array[Byte]], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. RichByteInput
  2. RichInput
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RichByteInput (stream: AInput[ByteBuffer])

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  7. def asText (charset: Charset): ATextInput

    Decode bytes as chars

    Decode bytes as chars

    charset

    the charset to use

    returns

    a decoder stream that uses specified charset

    See also

    DecoderInput

  8. def asText : ATextInput

    Decode bytes as chars

    Decode bytes as chars

    returns

    a decoder stream that uses default charset

    See also

    DecoderInput

  9. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  10. def content : Promise[Array[Byte]]

    Read the entire input and covert it to byte array.

    Read the entire input and covert it to byte array. The method closes underlying stream.

    returns

    a promise for byte array that is the entire stream

  11. def copyTo (out: AOutput[ByteBuffer], buffer: ByteBuffer, autoFlush: Boolean): Promise[Long]

    Forward the stream sequentially

    Forward the stream sequentially

    out

    the output stream

    buffer

    the buffer to use (the buffer must be ready for a read operation)

    autoFlush

    if true, the output is flushed after each operation (the completion of the operation is not waited)

    returns

    a promise that resolves to amount of forwarded bytes if the operation is successful

    Definition Classes
    RichInput
  12. def copyTo (out: AOutput[ByteBuffer], buffer: ByteBuffer): Promise[Long]

    Forward the stream sequentially

    Forward the stream sequentially

    out

    the output stream

    buffer

    the buffer to use

    returns

    a promise that resolves to amount of forwarded bytes if the operation is successful

    Definition Classes
    RichInput
  13. def copyTo2 (out: AOutput[ByteBuffer], buffer1: ByteBuffer, buffer2: ByteBuffer): Promise[Long]

    The two buffer version of forward operation.

    The two buffer version of forward operation. While one buffer is used for reading, other could be used for writing.

    out

    the output

    buffer1

    the first buffer

    buffer2

    the second buffer

    Definition Classes
    RichInput
  14. def digest (resolver: Resolver[Array[Byte]]): Wrapper

    Digest stream

    Digest stream

    resolver

    the resolver that would be notified when eof is reached

    returns

    digesting stream builder

  15. def discard (buffer: ByteBuffer): Promise[Long]

    Discard the stream sequentially

    Discard the stream sequentially

    buffer

    the buffer to use

    returns

    a promise that resolves to amount of discarded buffer elements if the operation is successful

    Definition Classes
    RichInput
  16. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  17. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  18. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  19. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef
  20. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  21. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  22. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  23. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  24. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  25. def read (data: Array[Byte]): Promise[Int]

    Array version of read operation

    Array version of read operation

    data

    the destination array

    returns

    the promise for amount of bytes read

    Definition Classes
    RichInput
  26. def read (data: Array[Byte], offset: Int, length: Int): Promise[Int]

    Array version of read operation

    Array version of read operation

    data

    the destination array

    offset

    the start offset

    length

    the length of the array

    returns

    the promise for amount of bytes read

    Definition Classes
    RichInput
  27. def readFully (buffer: ByteBuffer): Promise[Int]

    Read buffer fully, throwing exceptions if stream does not have enough data

    Read buffer fully, throwing exceptions if stream does not have enough data

    buffer

    the buffer to fill until buffer.remaining() == 0

    Definition Classes
    RichInput
  28. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  29. def toString (): String

    Definition Classes
    AnyRef → Any
  30. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  31. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  32. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from RichInput[ByteBuffer, Array[Byte]]

Inherited from AnyRef

Inherited from Any