Stream.Custom.Pipeline.ParallelFlow

All count

Counts all flow elements

Reverse filter

Disallows Stream.Flow elements satisfying the given function

Find optional any value

Finds any value or returns void option if not found

Flat map

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

Fold and convert

Folds and converts elements with a binary function

Process flow

Applies given function to each flow element

Simple map

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

Inspect

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

Optional reduce

Folds elements with a binary function or returns empty option when stream is empty

Optional long size

Many streams can return their current element count. If the information is not available, void option is returned

var s = (Int.min.Long <> Int.max.toLong).stream

s.sizeLongOpt.tp    // Prints Long.Opt(4294967296)

s = s.take(_ > 10)  // static sizing is lost

s.sizeLongOpt.tp    // Prints Long.Opt(VOID)

Optional size

Many streams can return their current element count. If the information is not available, void option is returned

Note: If size is known, but exceeds integer range, void option is returned. For theses cases use sizeLongOpt

 var s = ('a' <> 'z').stream

 s.sizeOpt.tp         // Prints Int.Opt(26)

 s = s.take(_ > 10)   // static sizing is lost

 s.sizeOpt.tp         // Prints Int.Opt(VOID)

Make String

tag returns this instance String representation, which should be used insted of toString

Filter

Only allow Stream.Flow elements satisfying the given function