Interface KeyValueStreamingChannel<K,​V>

  • Type Parameters:
    V - Value type.
    All Superinterfaces:
    StreamingChannel
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

    @FunctionalInterface
    public interface KeyValueStreamingChannel<K,​V>
    extends StreamingChannel
    Streaming API for multiple keys and values (tuples). You can implement this interface in order to receive a call to onKeyValue on every key-value.
    Since:
    5.0
    Author:
    Mark Paluch
    • Method Detail

      • onKeyValue

        void onKeyValue​(K key,
                        V value)
        Called on every incoming key/value pair.
        Parameters:
        key - the key
        value - the value