_build

trait _build[A]
class java.lang.Object
trait scala.Matchable
class Any

Def

@scala.annotation.targetName("stream")
def ~: ~[A]

Convert to stream

Convert to stream

Wraps ~~.Flow into regular stream.

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

Source
_build.scala
def collect[B](f: scala.PartialFunction[A, B]): ~~.Flow[B]

Partial map

Partial map

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

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

Reverse filter

Reverse filter

Disallows ~~.Flow elements satisfying the given function

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

Flat map

Flat map

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

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

Simple map

Simple map

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

Source
_build.scala
@scala.annotation.targetName("map_Opt")
def map_?[B](f: A => Opt[B]): ~~.Flow[B]

Optional map

Optional map

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

It the function returns void option, the elements are dropped

Source
_build.scala
def peek(c: A => Unit): ~~.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): ~~.Flow[A]

Indexed peek

Indexed peek

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

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

Filter

Filter

Only allow ~~.Flow elements satisfying the given function

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

Type filter

Type filter

Only lets elements of specified type

Source
_build.scala