public class Closeables extends Object
|Modifier and Type||Method and Description|
since 11.0 Please use
@Deprecated public static <E> CloseableIterator<E> iterator(org.reactivestreams.Publisher<E> publisher, int fetchSize)
CloseableIteratorby utilizing items fetched into an array and refetched as they are consumed from the iterator. The iterator when closed will also close the underlying
Subscriptionwhen subscribed to the publisher.
E- value type
publisher- the publisher to convert
fetchSize- how many entries to hold in memory at once in preparation for the iterators consumption
Copyright © 2021 JBoss by Red Hat. All rights reserved.