AsyncReader

zio.blocks.streams.io.Reader.AsyncReader
abstract class AsyncReader[+Elem] extends Reader[Elem]

A reader whose pull and lifecycle operations may suspend.

Attributes

Source
Reader.scala
Graph
Supertypes
class Reader[Elem]
class Object
trait Matchable
class Any
Self type
AsyncReader[Elem]

Members list

Value members

Abstract methods

def close(): encoding.Async[Unit]

Attributes

Source
Reader.scala
def isClosed: encoding.Async[Boolean]

Attributes

Source
Reader.scala
def read[A >: Elem](sentinel: A): encoding.Async[A]

Attributes

Source
Reader.scala
def readable(): encoding.Async[Boolean]

Attributes

Source
Reader.scala

Concrete methods

final override def ++[Elem2 >: Elem](next: => Reader[Elem2]): AsyncReader[Elem2]

Alias for concat.

Alias for concat.

Attributes

Definition Classes
Source
Reader.scala
final override def concat[Elem2 >: Elem](next: () => Reader[Elem2]): AsyncReader[Elem2]

Attributes

Definition Classes
Source
Reader.scala
final override def concatAsync[Elem2 >: Elem](next: () => encoding.Async[Reader[Elem2]]): AsyncReader[Elem2]

Attributes

Definition Classes
Source
Reader.scala
final protected def failSource[A](value: Any): encoding.Async[A]

Returns a failed Async with a trusted typed source error.

Returns a failed Async with a trusted typed source error.

Attributes

Source
Reader.scala
def readAll[A >: Elem](): encoding.Async[Chunk[A]]

Attributes

Source
Reader.scala
def readBoolean(_sentinel: Int)(implicit _ev: Elem <:< Boolean): encoding.Async[Int]

Attributes

Source
Reader.scala
def readByte(): encoding.Async[Int]

Attributes

Source
Reader.scala
def readBytes(dest: Array[Byte], offset: Int, length: Int)(implicit ev: Elem <:< Byte): encoding.Async[Int]

Attributes

Source
Reader.scala
def readChar(_sentinel: Int)(implicit _ev: Elem <:< Char): encoding.Async[Int]

Attributes

Source
Reader.scala
def readDouble(_sentinel: Double)(implicit _ev: Elem <:< Double): encoding.Async[Double]

Attributes

Source
Reader.scala
def readDoubles(dest: Array[Double], offset: Int, length: Int)(implicit ev: Elem <:< Double): encoding.Async[Int]

Attributes

Source
Reader.scala
def readFloat(_sentinel: Double)(implicit _ev: Elem <:< Float): encoding.Async[Double]

Attributes

Source
Reader.scala
def readFloats(dest: Array[Float], offset: Int, length: Int)(implicit ev: Elem <:< Float): encoding.Async[Int]

Attributes

Source
Reader.scala
def readInt(_sentinel: Long)(implicit _ev: Elem <:< Int): encoding.Async[Long]

Attributes

Source
Reader.scala
def readInts(dest: Array[Int], offset: Int, length: Int)(implicit ev: Elem <:< Int): encoding.Async[Int]

Attributes

Source
Reader.scala
def readLong(_sentinel: Long)(implicit _ev: Elem <:< Long): encoding.Async[Long]

Attributes

Source
Reader.scala
def readLongs(dest: Array[Long], offset: Int, length: Int)(implicit ev: Elem <:< Long): encoding.Async[Int]

Attributes

Source
Reader.scala
def readN[A >: Elem](n: Int): encoding.Async[Chunk[A]]

Attributes

Source
Reader.scala
def readShort(_sentinel: Int)(implicit _ev: Elem <:< Short): encoding.Async[Int]

Attributes

Source
Reader.scala
def readUpToN[A >: Elem](n: Int): encoding.Async[Chunk[A]]

Attributes

Source
Reader.scala
def reset(): encoding.Async[Unit]

Attributes

Source
Reader.scala
def setLimit(n: Long): encoding.Async[Boolean]

Attributes

Source
Reader.scala
def setRepeat(): encoding.Async[Boolean]

Attributes

Source
Reader.scala
def setSkip(n: Long): encoding.Async[Boolean]

Attributes

Source
Reader.scala
def skip(n: Long): encoding.Async[Unit]

Attributes

Source
Reader.scala
final protected def sourceError(value: Any): StreamError

Constructs a trusted typed source failure for custom Reader implementations.

Constructs a trusted typed source failure for custom Reader implementations.

Attributes

Source
Reader.scala
final override def withReleaseAsync(release: () => encoding.Async[Unit]): AsyncReader[Elem]

Attributes

Definition Classes
Source
Reader.scala

Inherited methods

def jvmType: JvmType

The primitive representation lane used by this reader.

The primitive representation lane used by this reader.

Attributes

Inherited from:
Reader
Source
Reader.scala
final def toSync: SyncReader[Elem]

Attributes

Inherited from:
AsyncReaderPlatform (hidden)
Source
AsyncReaderPlatform.scala