Class PrimaryOwnerOnlyCollector<T>

  • All Implemented Interfaces:
    Collector<T>

    public class PrimaryOwnerOnlyCollector<T>
    extends Object
    implements Collector<T>
    A Collector implementation that only waits for the primary owner.
    Since:
    9.0
    Author:
    Pedro Ruivo
    • Constructor Detail

      • PrimaryOwnerOnlyCollector

        public PrimaryOwnerOnlyCollector()
    • Method Detail

      • primaryException

        public void primaryException​(Throwable throwable)
        Description copied from interface: Collector
        The exception results of the primary owner.
        Specified by:
        primaryException in interface Collector<T>
        Parameters:
        throwable - the Throwable throw by the primary owner
      • primaryResult

        public void primaryResult​(T result,
                                  boolean success)
        Description copied from interface: Collector
        The write operation's return value.
        Specified by:
        primaryResult in interface Collector<T>
        Parameters:
        result - the operation's return value
        success - true if it was successful, false otherwise (for conditional operations).