List of operators where EagerFutureStream batches results

In some cases you can use xxxxFutures operators instead on the EagerFutureStream as a direct equivalent. Alternatively you can convert into a LazyFutureStream for the duration of the operation.e.g

  EagerFutureStream.parallelCommonBuilder()
                   .react(()->callService1(),()->callService2())
                   .convertToLazyStream()
                   .zip(otherStream)
                   .map(this::streamProcessZip)
                   .convertToEagerStream()  //batching occurs here
                   . continue processing

• limit : see limitFutures
• skip : see skipFutures
• slice : see sliceFutures
• zip : see zipFutures
• zipWithIndex : see zipFuturesWithIndex
• duplicate : see duplicateFutures
• scanLeft
• scanRight
• reverse : coming soon reverseFutures
• shuffle
• skipWhile
• skipUntil
• limitWhile
• intersperse
• distinct
• partition
• splitAt : see splitAtFutures
• combineLatest
• withLatest
• batchXXX / jitter/ fixedDelay / onePer /xPer : coming soon - batchXXXX won't rely on batching EFS results (more efficient)
• shard