telepath / com.github.giedomak.telepath.memorymanager.spliterator / PartitioningSpliterator

PartitioningSpliterator

class PartitioningSpliterator<E> : AbstractSpliterator<List<E>> (source)

Constructors

<init>

PartitioningSpliterator(spliterator: Spliterator<E>, partitionSize: Int)

Functions

estimateSize

fun estimateSize(): Long

tryAdvance

fun tryAdvance(action: Consumer<in List<E>>): Boolean

Companion Object Functions

partition

fun <E> partition(input: Stream<E>, partitionSize: Int): Stream<List<E>>
fun <E> partition(input: Stream<E>, partitionSize: Int, batchSize: Int): Stream<List<E>>