abstract class ZTransducer[-R, +E, -I, +O] extends AnyRef
- Self Type
- ZTransducer[R, E, I, O]
- Alphabetic
- By Inheritance
- ZTransducer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
&>[R1 <: R, E1 >: E, I1 <: I, O2](that: ZTransducer[R1, E1, I1, O2]): ZTransducer[R1, E1, I1, O2]
Symbolic alias for ZTransducer#zipRight.
-
final
def
<&[R1 <: R, E1 >: E, I1 <: I, O2](that: ZTransducer[R1, E1, I1, O2]): ZTransducer[R1, E1, I1, O]
Symbolic alias for ZTransducer#zipLeft.
-
final
def
<&>[R1 <: R, E1 >: E, I1 <: I, O2](that: ZTransducer[R1, E1, I1, O2]): ZTransducer[R1, E1, I1, (O, O2)]
Symbolic alias for ZTransducer#zip.
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
>>>[R1 <: R, E1 >: E, O2 >: O, I1 <: I, Z](that: ZSink[R1, E1, O2, Z]): ZSink[R1, E1, I1, 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( ... ) @native()
- final def contramap[J](f: (J) ⇒ I): ZTransducer[R, E, J, O]
- final def contramapM[R1 <: R, E1 >: E, J](f: (J) ⇒ ZIO[R1, E1, I]): ZTransducer[R1, E1, J, O]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
filter(p: (O) ⇒ Boolean): ZTransducer[R, E, I, O]
Filters the outputs of this transducer.
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- 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( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
zip[R1 <: R, E1 >: E, I1 <: I, O2](that: ZTransducer[R1, E1, I1, O2]): ZTransducer[R1, E1, I1, (O, O2)]
Zips this transducer with another point-wise and emits tuples of elements from both transducers.
-
def
zipLeft[R1 <: R, E1 >: E, I1 <: I, O2](that: ZTransducer[R1, E1, I1, O2]): ZTransducer[R1, E1, I1, O]
Zips this transducer with another point-wise, but keeps only the outputs of this transducer.
-
def
zipRight[R1 <: R, E1 >: E, I1 <: I, O2](that: ZTransducer[R1, E1, I1, O2]): ZTransducer[R1, E1, I1, O2]
Zips this transducer with another point-wise, but keeps only the outputs of the other transducer.
-
def
zipWith[R1 <: R, E1 >: E, I1 <: I, O2, O3](that: ZTransducer[R1, E1, I1, O2])(f: (O, O2) ⇒ O3): ZTransducer[R1, E1, I1, O3]
Zips this transducer with another point-wise and applies the function to the paired elements.