M
- type of the input messageOM
- type of the transformed messages@InterfaceStability.Unstable @FunctionalInterface public interface FlatMapFunction<M,OM> extends InitableFunction, ClosableFunction, java.io.Serializable
Modifier and Type | Method and Description |
---|---|
java.util.Collection<OM> |
apply(M message)
Transforms the provided message into a collection of 0 or more messages.
|
init
close