the input element type
the result type
Returns a Collector running the provided Collectors are run in parallel. The results are collected into an array.
the input element type
a tuple corresponding to the output types of the input collectors
a number of Collectors taking the same type of elements as input
Returns a Collector where the provided GenCollectors are run in parallel.
The given combineFun is applied to the array of results.
Note: due to type system limitations only the type of the first other collector is kept
the input element type
a tuple corresponding to the output types of the input collectors
the result type of the combineFun function
a function that takes the tupled output of all provided collectors, and combines them into one result value
a number of Collectors taking the same type of elements as input
Creates a new Collector object from element type A to result type R
the input element type
the state and result type
Returns a collector that feeds all input to the first col1 collector, and for each input element takes the output value
from col1 and feeds this value to col2. The output value is the value resulting from col2.
the input element type
the result type of col1
the result type of col2
the collector that receives the input
the collector that produces the output
Returns a Collector that processes every input element for which the given keyFun returns the same key value at most once.
the element key type
a function taking an input element and its index, and returning a key
Returns a Collector that returns each unique input element at most once.
Returns a Collector that skips the initial amount values of the input.
the amount of input values to skip
Returns a Collector that skips the last amount values of the input.
the amount of last input values to skip
Returns a Collector that only processes those elements that are not equal to their predecessor.
Returns a Collector where between each two elements, the given elem is added as extra input.
the element to insert between input elements
Returns a Collector where the output value(s) are mapped using the given mapFun
the new output type
a function from current output type R to new output type R2
Performs given monitorEffect for each input element. By default does a console.log with the given tag.
a tag to use with logging
the effect to perform for each input element
Returns a Collector where, at the occurence of given elem element, remove elements are skipped, and
insert elements are inserted, at most amount times.
the element to find
the amount of elements to skip when the element is found
the optional iterable to insert when the element is found
the maximum amount of time to replace an element
Returns a Collector that skips remove elements at those input elements for which pred returns true,
and then inserts th e optional iterable resulting from calling insert with the found element and its
index, at most amount times.
the predicate over input elements
the amount of elements to skip when pred is true
the iterable elements to insert when pred is true
the maximum amount of times to replace an input element
Returns a Collector that processes each nth element of the input elements.
specifies the index of which each element that has a multiple of nth will be processed
Returns a Collector that only process amount elements from the given from index of the input elements.
the index to start processing elements
the amount of elements to process
Returns a Collector that only processes the initial amount values of the input.
the amount of input values to process
Returns a Collector that only processes the last amount values of the input.
the amount of last input values to process
Creates a new Collector object from element type A to result type R
the definition of the state collector, containing:
initState: the initial state of the Collector, optionally lazynextState: a function taking the current state S and the next element A and returns the next state SstateToResult: a function that takes a state S and maps it to a result Rescape?: a predicate over a state S indicating whether its value can still ever changeGenerated using TypeDoc
A Collector taking input types of type A and returning results of type R