Skip to content

EagerFutureStream operations on underlying Futures

johnmcclean-aol edited this page Mar 10, 2015 · 2 revisions

EagerFutureStream operations on underlying Futures

EagerFutureSteam operations typically operate on the result of an operation rather than the underlying Stream of CompletableFutures. For example limit works by accepting the first X results and rejecting all subsequent ones.

eagerfuturestream limit

limitFutures on the other hand operates on the underlying Futures in much the same way as LazyFutureStream limit does. (LazyFutureStream typically operates on the underlying Futures as they can be infinite in size). e.g.

lazyfuturestream - limit

[Behaviour for LazyFutureStream limit and EagerFutureStream limitFutures]

The new Future operations are

limitFutures

skipFutures

eagerfuturestream - skipfutures

zipFutures

eagerfuturestream zipfutures

zipFuturesWithIndex

eagerfuturestream zipfutureswithindex

duplicateFutures

eagerfuturestream duplicatefutures

splitAtFutures

eagerfuturestream splitatfutures

sliceFutures

eagerfuturestream slicefutures

compared with standard slice

eagerfuturestream slice

Clone this wiki locally