transformation

open suspend override fun FlowCollector<Type>.transformation(input: Type)

Merger's implementation which merges values into one if it meets shouldBeMerged and getTransformationContract

Default behavior if contract is fails due to MoreThanOneContractApplicable function will use emitAllAccumulatedValues.

Parameters

input

is value to be analyzed and maybe split

See also