Uses of Interface
io.smallrye.mutiny.GroupedMulti

Packages that use GroupedMulti
Package
Description
io.smallrye.mutiny.groups
 

  • Uses of GroupedMulti in io.smallrye.mutiny.groups

    Methods in io.smallrye.mutiny.groups that return types with arguments of type GroupedMulti
    Modifier and Type
    Method
    Description
    <K> Multi<GroupedMulti<K,T>>
    MultiGroup.by(Function<? super T,? extends K> keyMapper)
    Groups items emitted by the upstream Multi based on a key extracted by the keyMapper function.
    <K> Multi<GroupedMulti<K,T>>
    MultiGroup.by(Function<? super T,? extends K> keyMapper, long prefetch)
    Groups items emitted by the upstream Multi based on a key extracted by the keyMapper function, with configurable prefetch buffer size.
    <K, V> Multi<GroupedMulti<K,V>>
    MultiGroup.by(Function<? super T,? extends K> keyMapper, Function<? super T,? extends V> valueMapper)
    Groups items emitted by the upstream Multi based on a key extracted by the keyMapper function, while transforming items using the valueMapper function.
    <K, V> Multi<GroupedMulti<K,V>>
    MultiGroup.by(Function<? super T,? extends K> keyMapper, Function<? super T,? extends V> valueMapper, long prefetch)
    Groups items emitted by the upstream Multi based on a key extracted by the keyMapper function, while transforming items using the valueMapper function, with configurable prefetch buffer size.