Source

interface Source<P : Processor>

Defines a provider of generic inputs that a Processor of type P can be attached to process over.

Types

Link copied to clipboard
object Noop : Source<Processor>

Convenience implementation of Source which does nothing when a Processor is provided to be attached.

Functions

Link copied to clipboard
abstract fun attach(processor: P): Closeable

Attaches the provided processor and returns a Closeable to release the connection once required. The source does not need to guarantee that the provided processor will be connected to as soon as attached since the the source may need to pull input data asynchronously.

Inheritors

Link copied to clipboard