object Transformer
- Source
- Transformer.scala
- Alphabetic
- By Inheritance
- Transformer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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 AnyRefAn internally-mutable "handler" that performs a Transformer's input/output logic. 
-    trait HandlerLinkage[+Out] extends AnyRefSpecialization 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 AnyRefRepresents 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 AnyValExtra methods for transformers whose Outtype is a Tuple2
-   implicit final  class TransformerParsingOps[In, A] extends AnyValExtra 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[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[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