ResponseT
- The type of a single response pageItemT
- The type of paginated member in a response pagepublic final class PaginatedItemsPublisher<ResponseT,ItemT> extends Object implements SdkPublisher<ItemT>
Modifier and Type | Class and Description |
---|---|
static interface |
PaginatedItemsPublisher.Builder |
Modifier and Type | Method and Description |
---|---|
static PaginatedItemsPublisher.Builder |
builder() |
void |
subscribe(<any> subscriber)
Subscribes to the publisher with the given
Consumer . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
adapt, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, limit, map
public static PaginatedItemsPublisher.Builder builder()
public void subscribe(<any> subscriber)
SdkPublisher
Consumer
. This consumer will be called for each event
published. There is no backpressure using this method if the Consumer dispatches processing asynchronously. If more
control over backpressure is required, consider using #subscribe(Subscriber)
.subscribe
in interface SdkPublisher<ItemT>
subscriber
- Consumer to process event.Copyright © 2022. All rights reserved.