net.sf.asyncobjects.asyncscala.nio.adapters

GenericOutputAdapter

class GenericOutputAdapter [S <: Closeable, B <: Buffer, A <: AnyRef] extends AOutput[B]

Output stream adapter. Note that it might block. So run it on thread pool vat

Attributes
abstract
Linear Supertypes
AOutput[B], ACloseable, Asynchronous, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. GenericOutputAdapter
  2. AOutput
  3. ACloseable
  4. Asynchronous
  5. AnyRef
  6. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new GenericOutputAdapter (output: S, bufferSize: Int)

Abstract Value Members

  1. def allocate (bufferSize: Int): A

    Attributes
    protected abstract
  2. def flush : Promise[Unit]

    Flush as much data from buffers as possible.

    Flush as much data from buffers as possible. Note that some data could remain in the buffers if it could not be readily converted (for example, incomplete code points in internal character buffer for net.sf.asyncobjects.nio.text.EncoderOutput).

    returns

    a promise that resolves when data finishes flushing

    Attributes
    abstract
    Definition Classes
    AOutput
  3. def fromBuffer (buffer: B, array: A, start: Int, size: Int): Unit

    Attributes
    protected abstract
  4. def write (in: S, array: A, offset: Int, length: Int): Unit

    Attributes
    protected abstract

Concrete 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 clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  8. def close : Promise[Unit]

    The #close() operation should be idempotent.

    The #close() operation should be idempotent. It should be no problem with closing the same object twice. The close operation should cancel the current operation if possible. The close should throw exception only in serious cases (for example in case of data loss, or inconsistent data)

    returns

    a promise that resolves when object finishes closing

    Definition Classes
    GenericOutputAdapterACloseable
  9. def eq (arg0: AnyRef): Boolean

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

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

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

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

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

    Attributes
    final
    Definition Classes
    Any
  15. var localBuffer : A

  16. def ne (arg0: AnyRef): Boolean

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  19. val output : S

    Attributes
    protected
  20. def synchronized [T0] (arg0: ⇒ T0): T0

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

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

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  25. def write (buffer: B): Promise[Unit]

    Write data to stream.

    Write data to stream. Note that the data will be written completely. If data could not be completely processed, it should be saved in stream's buffer.

    buffer

    a buffer with data to write

    returns

    a promise that resolves when data finished writing

    Definition Classes
    GenericOutputAdapterAOutput

Inherited from AOutput[B]

Inherited from ACloseable

Inherited from Asynchronous

Inherited from AnyRef

Inherited from Any