io.nem.symbol.sdk.api

Class PaginationStreamer<E,C extends SearchCriteria<C>>

java.lang.Object

io.nem.symbol.sdk.api.PaginationStreamer<E,C>

Direct Known Subclasses:

AccountPaginationStreamer, AccountRestrictionsPaginationStreamer, BlockPaginationStreamer, HashLockPaginationStreamer, MetadataPaginationStreamer, MosaicPaginationStreamer, MosaicRestrictionPaginationStreamer, NamespacePaginationStreamer, SecretLockPaginationStreamer, TransactionPaginationStreamer

public class PaginationStreamer<E,C extends SearchCriteria<C>>
extends java.lang.Object

Utility helper that stream pages of searches into an Observable.

A streamer will help users to walk through searches without knowing the underlying pagination implementation.

Constructor Summary

Constructors

Constructor and Description
PaginationStreamer(Searcher<E,C> searcher) Constructor

Method Summary

Modifier and Type	Method and Description
io.reactivex.Observable<E>	search(C criteria) Main method of the helper, it streams the results in observable only loading the pages when necessary.

Methods inherited from class java.lang.Object

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

Constructor Detail

PaginationStreamer

public PaginationStreamer(Searcher<E,C> searcher)

Constructor

Parameters:

searcher - the searcher repository

Method Detail

search

public io.reactivex.Observable<E> search(C criteria)

Main method of the helper, it streams the results in observable only loading the pages when necessary.

Parameters:

criteria - the criteria

Returns:

the observable of entities.