abstract class ZTransducer[-R, +E, -I, +O] extends AnyRef
- Self Type
- ZTransducer[R, E, I, O]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ZTransducer
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def >>>[R1 <: R, E1 >: E, O2 >: O, I1 <: I, L, Z](that: ZSink[R1, E1, O2, L, Z]): ZSink[R1, E1, I1, L, Z]
Compose this transducer with a sink, resulting in a sink that processes elements by piping them through this transducer and piping the results into the sink.
- def >>>[R1 <: R, E1 >: E, O2 >: O, O3](that: ZTransducer[R1, E1, O2, O3]): ZTransducer[R1, E1, I, O3]
Compose this transducer with another transducer, resulting in a composite transducer.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def contramap[J](f: (J) => I): ZTransducer[R, E, J, O]
Transforms the inputs of this transducer.
- final def contramapM[R1 <: R, E1 >: E, J](f: (J) => ZIO[R1, E1, I]): ZTransducer[R1, E1, J, O]
Effectually transforms the inputs of this transducer
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def filter(p: (O) => Boolean): ZTransducer[R, E, I, O]
Filters the outputs of this transducer.
- final def filterInput[I1 <: I](p: (I1) => Boolean): ZTransducer[R, E, I1, O]
Filters the inputs of this transducer.
- final def filterInputM[R1 <: R, E1 >: E, I1 <: I](p: (I1) => ZIO[R1, E1, Boolean]): ZTransducer[R1, E1, I1, O]
Effectually filters the inputs of this transducer.
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def map[P](f: (O) => P): ZTransducer[R, E, I, P]
Transforms the outputs of this transducer.
- final def mapChunks[O2](f: (Chunk[O]) => Chunk[O2]): ZTransducer[R, E, I, O2]
Transforms the chunks emitted by this transducer.
- final def mapChunksM[R1 <: R, E1 >: E, O2](f: (Chunk[O]) => ZIO[R1, E1, Chunk[O2]]): ZTransducer[R1, E1, I, O2]
Effectfully transforms the chunks emitted by this transducer.
- final def mapError[E1](f: (E) => E1): ZTransducer[R, E1, I, O]
Transforms the outputs of this transducer.
- final def mapM[R1 <: R, E1 >: E, P](f: (O) => ZIO[R1, E1, P]): ZTransducer[R1, E1, I, P]
Effectually transforms the outputs of this transducer
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val push: ZManaged[R, Nothing, (Option[Chunk[I]]) => ZIO[R, E, Chunk[O]]]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()