Class FlatteningSubscriber<U>

java.lang.Object
software.amazon.awssdk.utils.async.DelegatingSubscriber<Iterable<U>,U>
software.amazon.awssdk.utils.async.FlatteningSubscriber<U>
All Implemented Interfaces:
org.reactivestreams.Subscriber<Iterable<U>>

public class FlatteningSubscriber<U> extends DelegatingSubscriber<Iterable<U>,U>
  • Constructor Details

    • FlatteningSubscriber

      public FlatteningSubscriber(org.reactivestreams.Subscriber<? super U> subscriber)
  • Method Details