Class StreamingOutput.Subscriber<T>

    • Constructor Detail

      • Subscriber

        public Subscriber()
    • Method Detail

      • onNext

        public abstract void onNext​(T t)
        Data notification sent by the StreamingOutput.
        Parameters:
        t - element
      • onNext

        public void onNext​(Collection<T> outputTarget,
                           T t)
        Data notification sent by the StreamingOutput.
        Parameters:
        outputTarget - target
        t - element