Packages

object Reader

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Reader
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class ReaderDiscarded extends Exception
  2. trait Writable extends Reader with Writer with Closable

    A Reader that is linked with a Writer and close-ing is synchronous.

    A Reader that is linked with a Writer and close-ing is synchronous.

    Just as with readers and writers, only one outstanding read or write is permitted.

    For a proper close, it should only be done when no writes are outstanding:

    val rw = Reader.writable()
    ...
    rw.write(buf).before(rw.close())

    If a producer is interested in knowing when all writes have been read and the reader has seen the EOF, it can wait until the future returned by close() is satisfied:

    val rw = Reader.writable()
    ...
    rw.close().ensure {
      println("party on! ♪┏(・o・)┛♪ the Reader has seen the EOF")
    }

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. val Null: Reader
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  7. def concat(readers: AsyncStream[Reader]): Reader

    Convenient abstraction to read from a stream of Readers as if it were a single Reader.

  8. def copy(r: Reader, w: Writer): Future[Unit]

    Copy the bytes from a Reader to a Writer in chunks of size Writer.BufferSize.

    Copy the bytes from a Reader to a Writer in chunks of size Writer.BufferSize. The Writer is unmanaged, the caller is responsible for finalization and error handling, e.g.:

    Reader.copy(r, w) ensure w.close()
  9. def copy(r: Reader, w: Writer, n: Int): Future[Unit]

    Copy the bytes from a Reader to a Writer in chunks of size n.

    Copy the bytes from a Reader to a Writer in chunks of size n. The Writer is unmanaged, the caller is responsible for finalization and error handling, e.g.:

    Reader.copy(r, w, n) ensure w.close()
    n

    The number of bytes to read on each refill of the Writer.

  10. def copyMany(readers: AsyncStream[Reader], target: Writer): Future[Unit]

    Copy bytes from many Readers to a Writer.

    Copy bytes from many Readers to a Writer. The Writer is unmanaged, the caller is responsible for finalization and error handling, e.g.:

    Reader.copyMany(readers, writer) ensure writer.close()
  11. def copyMany(readers: AsyncStream[Reader], target: Writer, bufsize: Int): Future[Unit]

    Copy bytes from many Readers to a Writer.

    Copy bytes from many Readers to a Writer. The Writer is unmanaged, the caller is responsible for finalization and error handling, e.g.:

    Reader.copyMany(readers, writer) ensure writer.close()
    bufsize

    The number of bytes to read each time.

  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. def fromBuf(buf: Buf): Reader

    Reader from a Buf.

  16. def fromFile(f: File): Reader

    Create a new Reader for a File.

    Create a new Reader for a File.

    The resources held by the returned Reader are released on reading of EOF and Reader.discard().

    Annotations
    @throws( classOf[FileNotFoundException] ) @throws( classOf[SecurityException] )
    See also

    Readers.fromFile for a Java API

  17. def fromStream(s: InputStream): Reader

    Wrap InputStream with a Reader.

    Wrap InputStream with a Reader.

    Note that the given InputStream will be closed on reading of EOF and Reader.discard().

    See also

    Readers.fromStream for a Java API

  18. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. def readAll(r: Reader): Future[Buf]

    Read the entire bytestream presented by r.

  25. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  26. def toString(): String
    Definition Classes
    AnyRef → Any
  27. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  30. def writable(): Writable

    Create a new Writable which is a Reader that is linked with a Writer.

    Create a new Writable which is a Reader that is linked with a Writer.

    See also

    Readers.writable() for a Java API.

Inherited from AnyRef

Inherited from Any

Ungrouped