Reader

A reader whose pull and lifecycle operations may suspend.

A reader that is already closed. read returns null; readByte returns -1. The element type is Nothing — a closed reader emits no elements and widens by covariance to any Reader[Elem].

A reader backed by a zio.blocks.chunk.Chunk. Emits all elements in index order, then closes. No virtual thread or queue needed.

Wraps a java.io.InputStream as a Reader[Byte].

A reader backed by an Iterable. Emits all elements in iteration order, then closes. No virtual thread or queue needed.

A reader backed by a Scala Range. Emits integers in range order, then closes. No virtual thread or queue needed.

Wraps a java.io.Reader as a Reader[Char].

Creates an infinite reader that always emits a. The reader sets repeat mode on a single reader so it never closes.

A reader that restarts inner each time it closes cleanly. If it closes with an error (exception), the error is propagated. Used by Stream.Repeated.

Asynchronous counterpart of repeated(SyncReader).

Preserves the statically unknown reader kind at runtime.

A reader that emits exactly one element then closes. Primitive types (Int, Long, Float, Double, etc.) use SingletonPrim for zero-boxing; reference types use SingletonGeneric.

Creates a Reader that emits exactly one Boolean, zero-boxing on the read path.

Creates a Reader that emits exactly one Byte through the Byte lane.

Creates a Reader that emits exactly one Char, zero-boxing on the read path.

Creates a Reader that emits exactly one Double, zero-boxing on the read path.

Creates a Reader that emits exactly one Float, zero-boxing on the read path.

Creates a Reader that emits exactly one Int, zero-boxing on the read path.

Creates a Reader that emits exactly one Long, zero-boxing on the read path.

Creates a Reader that emits exactly one Short, zero-boxing on the read path.

A reader produced by unfolding state s with f. f returns None to signal completion, or Some((elem, nextState)) to emit an element and advance state. Closes when f returns None. No virtual thread or queue needed — read() never blocks.

Creates a native asynchronous Reader by unfolding state s with f. Exactly one state callback may be active. The next state is committed only when that callback succeeds while its reader generation is still current.