software.amazon.awssdk.core.pagination.async

Class PaginatedItemsPublisher<ResponseT,ItemT>

java.lang.Object

software.amazon.awssdk.core.pagination.async.PaginatedItemsPublisher<ResponseT,ItemT>

Type Parameters:

ResponseT - The type of a single response page

ItemT - The type of paginated member in a response page

All Implemented Interfaces:

org.reactivestreams.Publisher<ItemT>, SdkPublisher<ItemT>

public class PaginatedItemsPublisher<ResponseT,ItemT>
extends Object
implements SdkPublisher<ItemT>

A publisher to request for a stream of paginated items. The class can be used to request data for paginated items across multiple pages.

Constructor Summary

Constructors

Constructor and Description
PaginatedItemsPublisher(AsyncPageFetcher<ResponseT> nextPageFetcher, Function<ResponseT,Iterator<ItemT>> getIteratorFunction, boolean isLastPage)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super ItemT> subscriber)

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awssdk.core.pagination.async.SdkPublisher

forEach

Constructor Detail

PaginatedItemsPublisher

public PaginatedItemsPublisher(AsyncPageFetcher<ResponseT> nextPageFetcher,
                               Function<ResponseT,Iterator<ItemT>> getIteratorFunction,
                               boolean isLastPage)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ItemT> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ItemT>