Uses of Class
io.vavr.collection.Queue
Packages that use Queue
Package
Description
Beside
API the io.vavr package contains core types like (Checked)Functions and Tuples.Purely functional collections based on Traversable.
This package contains basic building blocks for creating fast, asynchronous, non-blocking parallel code.
-
Uses of Queue in io.vavr
-
Uses of Queue in io.vavr.collection
Fields in io.vavr.collection declared as QueueModifier and TypeFieldDescriptionprivate static final Queue<?> Queue.EMPTYLinkedHashMap.listStreamModule.AppendElements.queueMethods in io.vavr.collection that return QueueModifier and TypeMethodDescriptionQueue.asJavaMutable(@NonNull Consumer<? super List<T>> action) <R> Queue<R> Queue.collect(@NonNull PartialFunction<? super T, ? extends R> partialFunction) Queue.combinations()Queue.combinations(int k) Queue.distinct()Queue.distinctBy(@NonNull Comparator<? super T> comparator) Queue.distinctBy(@NonNull Function<? super T, ? extends U> keyExtractor) Queue.distinctByKeepLast(@NonNull Comparator<? super T> comparator) Queue.distinctByKeepLast(@NonNull Function<? super T, ? extends U> keyExtractor) Queue.drop(int n) Queue.dropRight(int n) Queue.dropRightUntil(@NonNull Predicate<? super T> predicate) Queue.dropRightWhile(@NonNull Predicate<? super T> predicate) static <T> Queue<T> Queue.empty()Returns the empty Queue.Enqueues a new element.Queue.enqueueAll(@NonNull Iterable<? extends T> elements) Enqueues the given elements.static <T> Queue<T> Returns a Queue containingnvalues supplied by a given Suppliers.static <T> Queue<T> Queue.fill(int n, T element) Returns a Queue containingntimes the givenelement<U> Queue<U> Queue.init()Queue.intersperse(T element) <U> Queue<U> <U> Queue<U> Queue.mapTo(U value) Queue.mapToVoid()static <T> Queue<T> Narrows aQueue<? extends T>toQueue<T>via a type-safe cast.static <T> Queue<T> Queue.of(T element) Returns a singletonQueue, i.e.static <T> Queue<T> Queue.of(T @NonNull ... elements) Creates a Queue of the given elements.Queue.ofAll(boolean @NonNull ... elements) Creates a Queue from boolean values.Queue.ofAll(byte @NonNull ... elements) Creates a Queue from byte values.Queue.ofAll(char @NonNull ... elements) Creates a Queue from char values.Queue.ofAll(double @NonNull ... elements) Creates a Queue from double values.Queue.ofAll(float @NonNull ... elements) Creates a Queue from float values.Queue.ofAll(int @NonNull ... elements) Creates a Queue from int values.Queue.ofAll(long @NonNull ... elements) Creates a Queue from long values.Queue.ofAll(short @NonNull ... elements) Creates a Queue from short values.static <T> Queue<T> Creates a Queue of the given elements.static <T> Queue<T> Creates a Queue that contains the elements of the givenStream.Queue.permutations()Queue.prependAll(@NonNull Iterable<? extends T> elements) Queue.range(char from, char toExclusive) Creates a Queue of characters starting fromfrom(inclusive) up totoExclusive(exclusive).Queue.range(int from, int toExclusive) Creates a Queue of int numbers starting fromfrom, extending totoExclusive - 1.Queue.range(long from, long toExclusive) Creates a Queue of long numbers starting fromfrom, extending totoExclusive - 1.Queue.rangeBy(char from, char toExclusive, int step) Creates a Queue of characters starting fromfrom(inclusive) up totoExclusive(exclusive), advancing by the specifiedstep.Queue.rangeBy(double from, double toExclusive, double step) Creates a Queue of double values starting fromfrom(inclusive) up totoExclusive(exclusive), advancing by the specifiedstep.Queue.rangeBy(int from, int toExclusive, int step) Creates a Queue of int numbers starting fromfrom, extending totoExclusive - 1, withstep.Queue.rangeBy(long from, long toExclusive, long step) Creates a Queue of long numbers starting fromfrom, extending totoExclusive - 1, withstep.Queue.rangeClosed(char from, char toInclusive) Creates a Queue of characters starting fromfrom(inclusive) up totoInclusive(inclusive).Queue.rangeClosed(int from, int toInclusive) Creates a Queue of int numbers starting fromfrom, extending totoInclusive.Queue.rangeClosed(long from, long toInclusive) Creates a Queue of long numbers starting fromfrom, extending totoInclusive.Queue.rangeClosedBy(char from, char toInclusive, int step) Creates a Queue of characters starting fromfrom(inclusive) up totoInclusive(inclusive), advancing by the specifiedstep.Queue.rangeClosedBy(double from, double toInclusive, double step) Creates a Queue of double values starting fromfrom(inclusive) up totoInclusive(inclusive), advancing by the specifiedstep.Queue.rangeClosedBy(int from, int toInclusive, int step) Creates a Queue of int numbers starting fromfrom, extending totoInclusive, withstep.Queue.rangeClosedBy(long from, long toInclusive, long step) Creates a Queue of long numbers starting fromfrom, extending totoInclusive, withstep.Queue.removeAt(int index) Queue.removeFirst(@NonNull Predicate<T> predicate) Queue.removeLast(@NonNull Predicate<T> predicate) Queue.replaceAll(T currentElement, T newElement) Queue.reverse()Queue.rotateLeft(int n) Queue.rotateRight(int n) <U> Queue<U> Queue.scanLeft(U zero, @NonNull BiFunction<? super U, ? super T, ? extends U> operation) <U> Queue<U> Queue.scanRight(U zero, @NonNull BiFunction<? super T, ? super U, ? extends U> operation) Queue.shuffle()Queue.slice(int beginIndex, int endIndex) Queue.sortBy(@NonNull Comparator<? super U> comparator, Function<? super T, ? extends U> mapper) <U extends Comparable<? super U>>
Queue<T> Queue.sorted()Queue.sorted(@NonNull Comparator<? super T> comparator) Queue.subSequence(int beginIndex) Queue.subSequence(int beginIndex, int endIndex) static <T> Queue<T> Returns a Queue containingnvalues of a given Functionfover a range of integer values from 0 ton - 1.Queue.tail()Queue.take(int n) Queue.takeRight(int n) Queue.takeRightUntil(@NonNull Predicate<? super T> predicate) Queue.takeRightWhile(@NonNull Predicate<? super T> predicate) Transposes the rows and columns of aQueuematrix.static <T> Queue<T> Creates a Queue from a seed value and a function.static <T,U> Queue <U> Queue.unfoldLeft(T seed, @NonNull Function<? super T, Option<Tuple2<? extends T, ? extends U>>> f) Creates a Queue from a seed value and a function.static <T,U> Queue <U> Queue.unfoldRight(T seed, @NonNull Function<? super T, Option<Tuple2<? extends U, ? extends T>>> f) Creates a Queue from a seed value and a function.<U,R> Queue <R> Queue.zipWith(@NonNull Iterable<? extends U> that, BiFunction<? super T, ? super U, ? extends R> mapper) Queue.zipWithIndex()<U> Queue<U> Queue.zipWithIndex(@NonNull BiFunction<? super T, ? super Integer, ? extends U> mapper) Methods in io.vavr.collection that return types with arguments of type QueueModifier and TypeMethodDescriptionQueue.collector()Returns aCollectorwhich may be used in conjunction withStream.collect(java.util.stream.Collector)to obtain aQueue.Queue.combinations()Queue.combinations(int k) Queue.crossProduct(int power) Queue.grouped(int size) Queue.permutations()Queue.sliding(int size) Queue.sliding(int size, int step) Queue.splitAt(int n) Queue.splitAt(int n) Queue.splitAtInclusive(@NonNull Predicate<? super T> predicate) Queue.splitAtInclusive(@NonNull Predicate<? super T> predicate) Transposes the rows and columns of aQueuematrix.Methods in io.vavr.collection with parameters of type QueueModifier and TypeMethodDescriptionstatic <T> Queue<T> Narrows aQueue<? extends T>toQueue<T>via a type-safe cast.Transposes the rows and columns of aQueuematrix.private static <K,V> LinkedHashMap <K, V> Construct Map with given values and key order.private static <K,V> LinkedHashMap <K, V> LinkedHashMap.wrapNonUnique(@NonNull Queue<Tuple2<K, V>> list, HashMap<K, V> map) Construct Map with given values and key order.Method parameters in io.vavr.collection with type arguments of type QueueModifier and TypeMethodDescription<U> UTransforms thisQueue.Transposes the rows and columns of aQueuematrix.Constructors in io.vavr.collection with parameters of type Queue -
Uses of Queue in io.vavr.concurrent
Fields in io.vavr.concurrent declared as QueueModifier and TypeFieldDescriptionFutureImpl.actionsThe queue of actions is filled when calling onComplete() before the Future is completed or cancelled.FutureImpl.waitersThe queue of waiters is filled when calling await() before the Future is completed or cancelled.Constructors in io.vavr.concurrent with parameters of type Queue