SplitBuilder

portals.api.builder.SplitBuilder
See theSplitBuilder companion object
trait SplitBuilder

Builder for splitting an atomic stream into multiple atomic streams.

Splits can be added to a splitter via the builder.splits.split method. Accessed from the application builder via builder.splits.

Attributes

Example
builder.splits.split[String](splitter, filter)
Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def split[T](splitter: AtomicSplitterRefKind[T], filter: T => Boolean): AtomicStreamRef[T]

Add a split to a splitter.

Add a split to a splitter.

Value parameters

filter

the filter to determine which events are filtered for the split

splitter

the splitter to add the split to

Attributes

Returns

the new split atomic stream

Example
builder.splits.split[String](splitter, filter)