_build

trait _build[A]
class java.lang.Object
trait scala.Matchable
class Any
class Stream.Flow[Stream.Flow.A]
class Stream.Custom.Pipeline.ParallelFlow[Stream.Custom.Pipeline.ParallelFlow.A]

Def

def collect[B](f: scala.PartialFunction[A, B]): Stream.Flow[B]

Partial map

Partial map

Creates a new Stream.Flow by applying a partial function to all elements of current Stream.Flow on which the function is defined.

Source
_build.scala
def drop(f: A => Boolean): Stream.Flow[A]

Reverse filter

Reverse filter

Disallows Stream.Flow elements satisfying the given function

Source
_build.scala
def flatMap[B](f: A => Stream[B]): Stream.Flow[B]

Flat map

Flat map

Creates a new Stream.Flow by applying given function to all elements of current Stream.Flow and concatenating the results

Source
_build.scala
def map[B](f: A => B): Stream.Flow[B]

Simple map

Simple map

Creates a new Stream.Flow where each element is a result of applying given function to current Stream.Flow elements

Source
_build.scala
def mapOpt[B](f: A => Opt[B]): Stream.Flow[B]

Optional map

Optional map

Creates a new Stream.Flow where each element is a result of applying given function to current Stream.Flow elements

It the function returns void option, the elements are dropped

Source
_build.scala
def peek(c: A => Unit): Stream.Flow[A]

Inspect

Inspect

The given function will be run for every passing stream flow element.

Source
_build.scala
def peekIndexed[U](c: (Int, A) => U, start: Int): Stream.Flow[A]

Indexed peek

Indexed peek

The given function will be executed for every passing element and its index.

Source
_build.scala
def stream: Stream[A]

Convert to stream

Convert to stream

Wraps Stream.Flow into regular stream.

If Stream.Flow is parallel, then this convertion can be very costly, and it is always prefferable to consume Stream.Flow without going back to Stream

Source
_build.scala
def take(f: A => Boolean): Stream.Flow[A]

Filter

Filter

Only allow Stream.Flow elements satisfying the given function

Source
_build.scala
def takeType[B](`evidence$1`: scala.reflect.ClassTag[B]): Stream.Flow[B]

Type filter

Type filter

Only lets elements of specified type

Source
_build.scala