RxPipeline

abstract val allBlocks: Iterable[RxBlock[_]]

All blocks that comprise this pipeline.

abstract def bindPorts(): Unit

Called to bind the input ports of the pipeline to the input ports of its constituents.

abstract val target: AbstractRxBlock[R]

The block whose output is exposed as the pipeline's output.

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

val blocksToReset: Iterable[RxBlock[_]]

The blocks that need to be reset each time the pipeline's reset method is called.

def clone(): AnyRef

def compute: Observable[R]

Computes the target block's output.

def debug(message: ⇒ String, args: Any*): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def error(message: ⇒ String, err: Throwable): Unit

def error(message: ⇒ String, args: Any*): Unit

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

val id: String

Generates block's id for logging.

def info(message: ⇒ String, args: Any*): Unit

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def observe: Observable[R]

The currently established Observable output.

lazy val output: Observable[R]

Returns the block's output as an Observable.

def reset(): Unit

Resets all internal blocks that need to be reset.

def shutdown(): Unit

Shuts down all its internal blocks.

final def synchronized[T0](arg0: ⇒ T0): T0

def to[U](block: RxTransformer[_ >: R, U]): block.type

Connects the output of this block to source input port of a transformer block.

def to[T](port: Port[_ >: R]): owner.type

Connects the output of this block to an input port of another block.

def toString(): String

def trace(message: ⇒ String, args: Any*): Unit

def unsubsribeOutput(): Unit

Cancels the output subscription.

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def warn(message: ⇒ String, err: Throwable): Unit

def warn(message: ⇒ String, args: Any*): Unit

def withEvents(name: String)(stream: Observable[R]): Observable[R]

Decorates the observable by adding listeners for its lifecycle events.

def ~>[U](block: RxTransformer[_ >: R, U]): block.type

Connects the output of this block to source input port of a transformer block.

def ~>[T](port: Port[_ >: R]): AbstractRxBlock[T]

Connects the output of this block to an input port of another block.