MBrace.Flow


Transformers

Namespace: MBrace.Flow.Internals.Consumers

Functions and values

Function or valueDescription
choose chooser flow
Signature: chooser:('T -> 'R option) -> flow:CloudFlow<'T> -> CloudFlow<'R>
Type parameters: 'T, 'R

Choose CloudFlow transformer.

collect f flow
Signature: f:('T -> 'b) -> flow:CloudFlow<'T> -> CloudFlow<'R>
Type parameters: 'T, 'b, 'R

Collect CloudFlow transformer.

filter predicate flow
Signature: predicate:('T -> bool) -> flow:CloudFlow<'T> -> CloudFlow<'T>
Type parameters: 'T

Filter flow transformer.

map f flow
Signature: f:('T -> 'R) -> flow:CloudFlow<'T> -> CloudFlow<'R>
Type parameters: 'T, 'R

Transforms each element of the input CloudFlow.

peek f flow
Signature: f:('T -> LocalCloud<unit>) -> flow:CloudFlow<'T> -> CloudFlow<'T>
Type parameters: 'T

Perform a monadic side-effect for each flow element.

Fork me on GitHub