Emit
An Emit[R, E, A, B] represents an asynchronous callback that can be called multiple times. The callback can be called with a value of type ZIO[R, Option[E], Chunk[A]], where succeeding with a Chunk[A] indicates to emit those elements, failing with Some[E] indicates to terminate with that error, and failing with None indicates to terminate with an end of stream signal.
Attributes
- Source
- ZStream.scala
- Graph
-
- Supertypes
Members list
Value members
Abstract methods
Attributes
- Source
- ZStream.scala
Concrete methods
Emits a chunk containing the specified values.
Terminates with a cause that dies with the specified Throwable.
Terminates with a cause that dies with a Throwable with the specified message.
Terminates with a cause that dies with a Throwable with the specified message.
Attributes
- Source
- ZStream.scala
Either emits the specified value if this Exit is a Success or else terminates with the specified cause if this Exit is a Failure.
Either emits the specified value if this Exit is a Success or else terminates with the specified cause if this Exit is a Failure.
Attributes
- Source
- ZStream.scala
Terminates with an end of stream signal.
Terminates with the specified error.
Either emits the success value of this effect or terminates the stream with the failure value of this effect.
Either emits the success value of this effect or terminates the stream with the failure value of this effect.
Attributes
- Source
- ZStream.scala
Either emits the success value of this effect or terminates the stream with the failure value of this effect.
Either emits the success value of this effect or terminates the stream with the failure value of this effect.
Attributes
- Source
- ZStream.scala
Terminates the stream with the specified cause.
Emits a chunk containing the specified value.