object Transformer
- Source
- Transformer.scala
- Alphabetic
- By Inheritance
- Transformer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- trait BoundHandler[-In] extends HandlerWrite[In]
A
Handlerwhich has been bound to some "downstream" receiver of outputs, so that thepushandfinishmethods will delegate to that downstream rather than requiring a downstream receiver to be passed as a method parameter.A
Handlerwhich has been bound to some "downstream" receiver of outputs, so that thepushandfinishmethods will delegate to that downstream rather than requiring a downstream receiver to be passed as a method parameter.- In
The handler's input type
- trait Handler[-In, +Out] extends AnyRef
An internally-mutable "handler" that performs a Transformer's input/output logic.
- trait HandlerLinkage[+Out] extends AnyRef
Specialization for a
BoundHandlerwhose "downstream" can be changed at will.Specialization for a
BoundHandlerwhose "downstream" can be changed at will.- Out
The handler's output type
- trait HandlerWrite[-Out] extends AnyRef
Represents the "downstream" of a handler.
Represents the "downstream" of a handler. Whenever a handler is told to
pushorfinish, it uses a HandlerWrite to receive its output. A HandlerWrite could be an object that collects the values to a buffer which you can manually inspect later (see BoundHandler.ToBuilder), or a wrapper around some secondary Handler i.e. the next transformation step.- Out
The output event type from the upstream handler, which acts as the input to this receiver
- trait Stateless[-In, +Out] extends Transformer[In, Out] with Handler[In, Out]
A stateless transformer acts as its own handler
A stateless transformer acts as its own handler
- In
The incoming event type
- Out
The outgoing event type
- implicit final class TransformerKVParsingOps[In, K, V] extends AnyVal
Extra methods for transformers whose
Outtype is a Tuple2 - implicit final class TransformerParsingOps[In, A] extends AnyVal
Extra transformer methods that had to be defined separately from the trait due to either
InorOutneeding to be invariant.
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 apply[In]: TransformerApplyWithBoundInput[In]
Convenience for creating transformers whose input type is bound to
In.Convenience for creating transformers whose input type is bound to
In.This is particularly nice when the
Outtype can be inferred by the compiler, e.g.Transformer[Int].op(i => Emit.one(i * 2)) // versus Transformer.op[Int, Int](i => Emit.one(i * 2))
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def collect[In, Out](pf: PartialFunction[In, Out]): Transformer[In, Out]
- def drop[In](n: Int): Transformer[In, In]
- def dropWhile[In](f: (In) => Boolean): Transformer[In, In]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def filter[In](f: (In) => Boolean): Transformer[In, In]
- def finalize(): Unit
- Attributes
- protected[java.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()
- def identity[In]: Transformer[In, In]
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[In, Out](f: (In) => Out): Transformer[In, Out]
- def mapFlatten[In, Out](f: (In) => Iterable[Out]): Transformer[In, Out]
- 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()
- def spacFrame[In](elems: SpacTraceElement*): Transformer[In, In]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def take[In](n: Int): Transformer[In, In]
- def takeWhile[In](f: (In) => Boolean): Transformer[In, In]
- def tap[In](f: (In) => Unit): Transformer[In, In]
- 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()
- object BoundHandler
- object Handler