object Handler
- Source
- Transformer.scala
- Alphabetic
- By Inheritance
- Handler
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def bindDownstream[In, Out](inner: Handler[In, Out], downstream: BoundHandler[Out]): BoundHandler[In]
Combine a handler with a predetermined "downstream", creating a
BoundHandler
whosepush
andfinish
methods delegate to thatdownstream
receiver instead of needing to accept one as a parameter.Combine a handler with a predetermined "downstream", creating a
BoundHandler
whosepush
andfinish
methods delegate to thatdownstream
receiver instead of needing to accept one as a parameter.This is useful for implementing more complex handlers, or when interfacing with a Transformer without a Parser, e.g. in order to collect outputs from a transformer into a buffer.
- In
The input event type
- Out
The output event type
- inner
The "upstream" handler
- downstream
The "downstream" handler which will receive outputs from
inner
- returns
A sink for
In
events which uses theinner
handler to receive events, and thedownstream
handler to receive outputs frominner
- def bindVariableDownstream[In, Out](inner: Handler[In, Out]): BoundHandler[In] with HandlerLinkage[Out]
Combine an existing handler with a variable "downstream" handler, creating a
BoundHandler
whosepush
andfinish
methods delegate to whatever the current "downstream" is, instead of needing to accept the downstream as a parameter.Combine an existing handler with a variable "downstream" handler, creating a
BoundHandler
whosepush
andfinish
methods delegate to whatever the current "downstream" is, instead of needing to accept the downstream as a parameter.This is similar to
bindDownstream
except that you can swap out the actual downstream handler at any time. This primarily exists as a helper for wiring chains of transformers together; you probably don't want to use this directly. - def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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 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 protect[In, Out](inner: Handler[In, Out]): Handler[In, Out]
Wrap an existing transformer handler, protecting it from misuse of the Handler interface methods.
Wrap an existing transformer handler, protecting it from misuse of the Handler interface methods. The returned handler guarantees that once the inner handler returns a
Stop
signal, throws an exception, or is told tofinish()
, the returned handler will no-op for subsequent calls tofinish
orpush
.Furthermore, exceptions thrown by the inner handler will be passed to the inner handler's
bubbleUp
method, allowing for possible transformation of errors thrown by the inner handler as if that inner handler had try/catch wrappers around all of its own logic.- In
The input event type
- Out
The output event type
- inner
The handler to wrap
- returns
A new handler which wraps the
inner
one, protecting it against interface misuse.
- 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()