Package io.smallrye.reactive.messaging.providers.helpers

Class DefaultKeyedMultiOfMessage<K,V>

java.lang.Object
io.smallrye.mutiny.operators.AbstractMulti<org.eclipse.microprofile.reactive.messaging.Message<V>>
io.smallrye.reactive.messaging.providers.helpers.DefaultKeyedMultiOfMessage<K,V>
Type Parameters:
K - type of key
V - type of value
All Implemented Interfaces:
io.smallrye.mutiny.GroupedMulti<K,org.eclipse.microprofile.reactive.messaging.Message<V>>, io.smallrye.mutiny.Multi<org.eclipse.microprofile.reactive.messaging.Message<V>>, io.smallrye.reactive.messaging.keyed.KeyedMulti<K,org.eclipse.microprofile.reactive.messaging.Message<V>>, Flow.Publisher<org.eclipse.microprofile.reactive.messaging.Message<V>>
public class DefaultKeyedMultiOfMessage<K,V> extends io.smallrye.mutiny.operators.AbstractMulti<org.eclipse.microprofile.reactive.messaging.Message<V>> implements io.smallrye.reactive.messaging.keyed.KeyedMulti<K,org.eclipse.microprofile.reactive.messaging.Message<V>>
The default implementation of KeyedMulti for the KeyedMulti<K, Message<V>>.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultKeyedMultiOfMessage(K key, io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<V>> grouped)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    K
    key()
     
    void
    subscribe(io.smallrye.mutiny.subscription.MultiSubscriber<? super org.eclipse.microprofile.reactive.messaging.Message<V>> subscriber)
     

    Methods inherited from class io.smallrye.mutiny.operators.AbstractMulti

    broadcast, cache, capDemandsUsing, collect, convert, emitOn, emitOn, group, ifNoItem, log, log, onCancellation, onCompletion, onFailure, onFailure, onFailure, onItem, onOverflow, onRequest, onSubscription, onTermination, paceDemand, pauseDemand, runSubscriptionOn, select, skip, subscribe, subscribe, toHotStream, toUni, withContext

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface java.util.concurrent.Flow.Publisher

    subscribe

    Methods inherited from interface io.smallrye.mutiny.Multi

    attachContext, broadcast, cache, call, call, capDemandsTo, capDemandsUsing, collect, concatMap, convert, emitOn, emitOn, filter, flatMap, group, ifNoItem, invoke, invoke, log, log, map, onCancellation, onCompletion, onFailure, onFailure, onFailure, onItem, onOverflow, onRequest, onSubscription, onTermination, paceDemand, pauseDemand, plug, runSubscriptionOn, select, skip, split, stage, subscribe, toHotStream, toUni, withContext

  • Constructor Details

    • DefaultKeyedMultiOfMessage

      public DefaultKeyedMultiOfMessage(K key, io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<V>> grouped)

  • Method Details

    • subscribe

      public void subscribe(io.smallrye.mutiny.subscription.MultiSubscriber<? super org.eclipse.microprofile.reactive.messaging.Message<V>> subscriber)
      Overrides:
      subscribe in class io.smallrye.mutiny.operators.AbstractMulti<org.eclipse.microprofile.reactive.messaging.Message<V>>

    • key

      public K key()
      Specified by:
      key in interface io.smallrye.mutiny.GroupedMulti<K,V>