org.spf4j.base

Class XCollectors

java.lang.Object

org.spf4j.base.XCollectors

public final class XCollectors
extends Object

Author:

Zoltan Farkas

Method Summary

Modifier and Type	Method and Description
static <T,A,R> Collector<T,?,R>	filtering(Predicate<? super T> predicate, Collector<? super T,A,R> downstream) THis is a backport from JDK9.
static <T> Collector<T,?,ArrayDeque<T>>	last(int limit)
static <T,X extends T> Collector<T,ArrayDeque<T>,ArrayDeque<T>>	last(int limit, X addIfLimited)
static <T,X extends T,D extends Deque<T>> Collector<T,D,D>	last(Supplier<D> dqSupp, int limit, X addIfLimited)
static <T> void	limitDequeue(Deque<T> l1, int limit, T addIfLimited)

Methods inherited from class java.lang.Object

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

Method Detail

last

public static <T> Collector<T,?,ArrayDeque<T>> last(int limit)

last

public static <T,X extends T> Collector<T,ArrayDeque<T>,ArrayDeque<T>> last(int limit,
                                                                            X addIfLimited)

last

public static <T,X extends T,D extends Deque<T>> Collector<T,D,D> last(Supplier<D> dqSupp,
                                                                       int limit,
                                                                       X addIfLimited)

limitDequeue

public static <T> void limitDequeue(Deque<T> l1,
                                    int limit,
                                    T addIfLimited)

filtering

public static <T,A,R> Collector<T,?,R> filtering(Predicate<? super T> predicate,
                                                 Collector<? super T,A,R> downstream)

THis is a backport from JDK9.