Uses of Interface
io.vavr.collection.Stream

Packages that use Stream

Package	Description
io.vavr	Beside API the io.vavr package contains core types like (Checked)Functions and Tuples.
io.vavr.collection	Purely functional collections based on Traversable.

Uses of Stream in io.vavr

Methods in io.vavr that return Stream

Modifier and Type	Method	Description
static <T> Stream<T>	API.Stream()	Alias for empty()
static <T> Stream<T>	API.Stream(T element)	Alias for of(Object)
static <T> Stream<T>	API.Stream(T @NonNull ... elements)	Alias for of(Object...)
default Stream<T>	Value.toStream()	Converts this to a Stream.

Uses of Stream in io.vavr.collection

Classes in io.vavr.collection that implement Stream

Modifier and Type	Class	Description
static class	Stream.Cons<T>	Non-empty Stream, consisting of a head, and tail.
static class	Stream.Empty<T>	The empty Stream.
static class	StreamModule.AppendElements<T>
static class	StreamModule.ConsImpl<T>

Fields in io.vavr.collection with type parameters of type Stream

Modifier and Type	Field	Description
private java.util.function.Supplier<Stream<T>>	StreamModule.StreamIterator.current
(package private) Lazy<Stream<T>>	Stream.Cons.tail

Methods in io.vavr.collection that return Stream

Modifier and Type	Method	Description
default Stream<T>	Stream.append(T element)
Stream<T>	StreamModule.AppendElements.append(T element)
default Stream<T>	Stream.appendAll(@NonNull java.lang.Iterable<? extends T> elements)
Stream<T>	StreamModule.AppendElements.appendAll(@NonNull java.lang.Iterable<? extends T> elements)
default Stream<T>	Stream.appendSelf(@NonNull java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)	Appends itself to the end of stream with mapper function.
static <T> Stream<Stream<T>>	StreamModule.Combinations.apply(Stream<T> elements, int k)
static <T> Stream<T>	StreamModule.DropRight.apply(List<T> front, List<T> rear, Stream<T> remaining)
default Stream<T>	Stream.asJava(@NonNull java.util.function.Consumer<? super java.util.List<T>> action)
default Stream<T>	Stream.asJavaMutable(@NonNull java.util.function.Consumer<? super java.util.List<T>> action)
default <R> Stream<R>	Stream.collect(@NonNull PartialFunction<? super T,? extends R> partialFunction)
default Stream<Stream<T>>	Stream.combinations()
default Stream<Stream<T>>	Stream.combinations(int k)
static <T> Stream<T>	Stream.concat(@NonNull java.lang.Iterable<? extends java.lang.Iterable<? extends T>> iterables)	Lazily creates a Stream in O(1) which traverses along the concatenation of the given iterables.
static <T> Stream<T>	Stream.concat(@NonNull java.lang.Iterable<? extends T> @NonNull ... iterables)	Lazily creates a Stream in O(1) which traverses along the concatenation of the given iterables.
static <T> Stream<T>	Stream.cons(T head, @NonNull java.util.function.Supplier<? extends Stream<? extends T>> tailSupplier)	Constructs a Stream of a head element and a tail supplier.
static <T> Stream<T>	Stream.continually(@NonNull java.util.function.Supplier<? extends T> supplier)	Generates an (theoretically) infinitely long Stream using a value Supplier.
static <T> Stream<T>	Stream.continually(T t)	Repeats an element infinitely often.
static <T> Stream<T>	StreamModule.StreamFactory.create(java.util.Iterator<? extends T> iterator)
default Stream<T>	Stream.cycle()	Repeat the elements of this Stream infinitely.
default Stream<T>	Stream.cycle(int count)	Repeat the elements of this Stream count times.
default Stream<T>	Stream.distinct()
default Stream<T>	Stream.distinctBy(@NonNull java.util.Comparator<? super T> comparator)
default <U> Stream<T>	Stream.distinctBy(@NonNull java.util.function.Function<? super T,? extends U> keyExtractor)
default Stream<T>	Stream.distinctByKeepLast(@NonNull java.util.Comparator<? super T> comparator)
default <U> Stream<T>	Stream.distinctByKeepLast(@NonNull java.util.function.Function<? super T,? extends U> keyExtractor)
default Stream<T>	Stream.drop(int n)
default Stream<T>	Stream.dropRight(int n)
default Stream<T>	Stream.dropRightUntil(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.dropRightWhile(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.dropUntil(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.dropWhile(@NonNull java.util.function.Predicate<? super T> predicate)
static <T> Stream<T>	Stream.empty()	Returns the single instance of Empty.
default Stream<T>	Stream.extend(@NonNull java.util.function.Function<? super T,? extends T> nextFunction)	Extends (continues) this Stream with a Stream of values created by applying consecutively provided Function to the last element of the original Stream.
default Stream<T>	Stream.extend(@NonNull java.util.function.Supplier<? extends T> nextSupplier)	Extends (continues) this Stream with values provided by a Supplier
default Stream<T>	Stream.extend(T next)	Extends (continues) this Stream with a constantly repeated value.
static <T> Stream<T>	Stream.fill(int n, @NonNull java.util.function.Supplier<? extends T> s)	Returns a Stream containing n values supplied by a given Supplier s.
static <T> Stream<T>	Stream.fill(int n, T element)	Returns a Stream containing n times the given element
default Stream<T>	Stream.filter(@NonNull java.util.function.Predicate<? super T> predicate)
default <U> Stream<U>	Stream.flatMap(@NonNull java.util.function.Function<? super T,? extends java.lang.Iterable<? extends U>> mapper)
static Stream<java.lang.Integer>	Stream.from(int value)	Returns an infinitely long Stream of int values starting from from.
static Stream<java.lang.Integer>	Stream.from(int value, int step)	Returns an infinite long Stream of int values starting from value and spaced by step.
static Stream<java.lang.Long>	Stream.from(long value)	Returns an infinitely long Stream of long values starting from from.
static Stream<java.lang.Long>	Stream.from(long value, long step)	Returns an infinite long Stream of long values starting from value and spaced by step.
default Stream<T>	Stream.init()
default Stream<T>	Stream.insert(int index, T element)
default Stream<T>	Stream.insertAll(int index, @NonNull java.lang.Iterable<? extends T> elements)
default Stream<T>	Stream.intersperse(T element)
static <T> Stream<T>	Stream.iterate(@NonNull java.util.function.Supplier<? extends Option<? extends T>> supplier)	Generates a (theoretically) infinitely long Stream using a repeatedly invoked supplier that provides a Some for each next value and a None for the end.
static <T> Stream<T>	Stream.iterate(T seed, @NonNull java.util.function.Function<? super T,? extends T> f)	Generates a (theoretically) infinitely long Stream using a function to calculate the next value based on the previous.
default Stream<T>	Stream.leftPadTo(int length, T element)
default <U> Stream<U>	Stream.map(@NonNull java.util.function.Function<? super T,? extends U> mapper)
default <U> Stream<U>	Stream.mapTo(U value)
default Stream<java.lang.Void>	Stream.mapToVoid()
static <T> Stream<T>	Stream.narrow(Stream<? extends T> stream)	Narrows a widened Stream<? extends T> to Stream<T> by performing a type-safe cast.
static <T> Stream<T>	Stream.of(T element)	Returns a singleton Stream, i.e.
static <T> Stream<T>	Stream.of(T @NonNull ... elements)	Creates a Stream of the given elements.
static Stream<java.lang.Boolean>	Stream.ofAll(boolean @NonNull ... elements)	Creates a Stream from boolean values.
static Stream<java.lang.Byte>	Stream.ofAll(byte @NonNull ... elements)	Creates a Stream from byte values.
static Stream<java.lang.Character>	Stream.ofAll(char @NonNull ... elements)	Creates a Stream from char values.
static Stream<java.lang.Double>	Stream.ofAll(double @NonNull ... elements)	Creates a Stream values double values.
static Stream<java.lang.Float>	Stream.ofAll(float @NonNull ... elements)	Creates a Stream from float values.
static Stream<java.lang.Integer>	Stream.ofAll(int @NonNull ... elements)	Creates a Stream from int values.
static Stream<java.lang.Long>	Stream.ofAll(long @NonNull ... elements)	Creates a Stream from long values.
static Stream<java.lang.Short>	Stream.ofAll(short @NonNull ... elements)	Creates a Stream from short values.
static <T> Stream<T>	Stream.ofAll(@NonNull java.lang.Iterable<? extends T> elements)	Creates a Stream of the given elements.
static <T> Stream<T>	Stream.ofAll(@NonNull java.util.stream.Stream<? extends T> javaStream)	Creates a Stream that contains the elements of the given Stream.
default Stream<T>	Stream.orElse(@NonNull java.lang.Iterable<? extends T> other)
default Stream<T>	Stream.orElse(@NonNull java.util.function.Supplier<? extends java.lang.Iterable<? extends T>> supplier)
default Stream<T>	Stream.padTo(int length, T element)
default Stream<T>	Stream.patch(int from, @NonNull java.lang.Iterable<? extends T> that, int replaced)
default Stream<T>	Stream.peek(@NonNull java.util.function.Consumer<? super T> action)
default Stream<Stream<T>>	Stream.permutations()
default Stream<T>	Stream.prepend(T element)
default Stream<T>	Stream.prependAll(@NonNull java.lang.Iterable<? extends T> elements)
static Stream<java.lang.Character>	Stream.range(char from, char toExclusive)	Creates a Stream of char numbers starting from from, extending to toExclusive - 1.
static Stream<java.lang.Integer>	Stream.range(int from, int toExclusive)	Creates a Stream of int numbers starting from from, extending to toExclusive - 1.
static Stream<java.lang.Long>	Stream.range(long from, long toExclusive)	Creates a Stream of long numbers starting from from, extending to toExclusive - 1.
static Stream<java.lang.Character>	Stream.rangeBy(char from, char toExclusive, int step)	Creates a Stream of char numbers starting from from, extending to toExclusive - 1, with step.
static Stream<java.lang.Double>	Stream.rangeBy(double from, double toExclusive, double step)	Creates a Stream of double numbers starting from from, extending up to but not including toExclusive, with step.
static Stream<java.lang.Integer>	Stream.rangeBy(int from, int toExclusive, int step)	Creates a Stream of int numbers starting from from, extending to toExclusive - 1, with step.
static Stream<java.lang.Long>	Stream.rangeBy(long from, long toExclusive, long step)	Creates a Stream of long numbers starting from from, extending to toExclusive - 1, with step.
static Stream<java.lang.Character>	Stream.rangeClosed(char from, char toInclusive)	Creates a Stream of char numbers starting from from, extending to toInclusive.
static Stream<java.lang.Integer>	Stream.rangeClosed(int from, int toInclusive)	Creates a Stream of int numbers starting from from, extending to toInclusive.
static Stream<java.lang.Long>	Stream.rangeClosed(long from, long toInclusive)	Creates a Stream of long numbers starting from from, extending to toInclusive.
static Stream<java.lang.Character>	Stream.rangeClosedBy(char from, char toInclusive, int step)	Creates a Stream of char values starting from from, extending to toInclusive, with step.
static Stream<java.lang.Double>	Stream.rangeClosedBy(double from, double toInclusive, double step)	Creates a Stream of double values starting from from, extending to toInclusive, with step.
static Stream<java.lang.Integer>	Stream.rangeClosedBy(int from, int toInclusive, int step)	Creates a Stream of int numbers starting from from, extending to toInclusive, with step.
static Stream<java.lang.Long>	Stream.rangeClosedBy(long from, long toInclusive, long step)	Creates a Stream of long numbers starting from from, extending to toInclusive, with step.
default Stream<T>	Stream.reject(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.remove(T element)
default Stream<T>	Stream.removeAll(@NonNull java.lang.Iterable<? extends T> elements)
default Stream<T>	Stream.removeAll(@NonNull java.util.function.Predicate<? super T> predicate)	Deprecated.
default Stream<T>	Stream.removeAll(T element)
default Stream<T>	Stream.removeAt(int index)
default Stream<T>	Stream.removeFirst(@NonNull java.util.function.Predicate<T> predicate)
default Stream<T>	Stream.removeLast(@NonNull java.util.function.Predicate<T> predicate)
default Stream<T>	Stream.replace(T currentElement, T newElement)
default Stream<T>	Stream.replaceAll(T currentElement, T newElement)
default Stream<T>	Stream.retainAll(@NonNull java.lang.Iterable<? extends T> elements)
default Stream<T>	Stream.reverse()
default Stream<T>	Stream.rotateLeft(int n)
default Stream<T>	Stream.rotateRight(int n)
default Stream<T>	Stream.scan(T zero, @NonNull java.util.function.BiFunction<? super T,? super T,? extends T> operation)
default <U> Stream<U>	Stream.scanLeft(U zero, @NonNull java.util.function.BiFunction<? super U,? super T,? extends U> operation)
default <U> Stream<U>	Stream.scanRight(U zero, @NonNull java.util.function.BiFunction<? super T,? super U,? extends U> operation)
default Stream<T>	Stream.shuffle()
default Stream<T>	Stream.slice(int beginIndex, int endIndex)
default <U> Stream<T>	Stream.sortBy(@NonNull java.util.Comparator<? super U> comparator, java.util.function.Function<? super T,? extends U> mapper)
default <U extends java.lang.Comparable<? super U>> Stream<T>	Stream.sortBy(@NonNull java.util.function.Function<? super T,? extends U> mapper)
default Stream<T>	Stream.sorted()
default Stream<T>	Stream.sorted(@NonNull java.util.Comparator<? super T> comparator)
default Stream<T>	Stream.subSequence(int beginIndex)
default Stream<T>	Stream.subSequence(int beginIndex, int endIndex)
static <T> Stream<T>	Stream.tabulate(int n, @NonNull java.util.function.Function<? super java.lang.Integer,? extends T> f)	Returns a Stream containing n values of a given Function f over a range of integer values from 0 to n - 1.
Stream<T>	Stream.Empty.tail()
Stream<T>	Stream.tail()
Stream<T>	StreamModule.AppendElements.tail()
Stream<T>	StreamModule.ConsImpl.tail()
default Stream<T>	Stream.take(int n)
default Stream<T>	Stream.takeRight(int n)
default Stream<T>	Stream.takeRightUntil(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.takeRightWhile(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.takeUntil(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<T>	Stream.takeWhile(@NonNull java.util.function.Predicate<? super T> predicate)
static <T> Stream<Stream<T>>	Stream.transpose(@NonNull Stream<Stream<T>> matrix)	Transposes the rows and columns of a Stream matrix.
static <T> Stream<Tree.Node<T>>	TreeModule.traverseInOrder(@NonNull Tree.Node<T> node)
static <T> Stream<Tree.Node<T>>	TreeModule.traverseLevelOrder(@NonNull Tree.Node<T> node)
static <T> Stream<Tree.Node<T>>	TreeModule.traversePostOrder(@NonNull Tree.Node<T> node)
static <T> Stream<Tree.Node<T>>	TreeModule.traversePreOrder(@NonNull Tree.Node<T> node)
static <T> Stream<T>	Stream.unfold(T seed, @NonNull java.util.function.Function<? super T,Option<Tuple2<? extends T,? extends T>>> f)	Creates a Stream from a seed value and a function.
static <T,U> Stream<U>	Stream.unfoldLeft(T seed, @NonNull java.util.function.Function<? super T,Option<Tuple2<? extends T,? extends U>>> f)	Creates a Stream from a seed value and a function.
static <T,U> Stream<U>	Stream.unfoldRight(T seed, @NonNull java.util.function.Function<? super T,Option<Tuple2<? extends U,? extends T>>> f)	Creates a Stream from a seed value and a function.
default Stream<T>	Stream.update(int index, @NonNull java.util.function.Function<? super T,? extends T> updater)
default Stream<T>	Stream.update(int index, T element)
Stream<V>	HashMap.values()
default <U> Stream<Tuple2<T,U>>	Stream.zip(@NonNull java.lang.Iterable<? extends U> that)
default <U> Stream<Tuple2<T,U>>	Stream.zipAll(@NonNull java.lang.Iterable<? extends U> iterable, T thisElem, U thatElem)
default <U,R> Stream<R>	Stream.zipWith(@NonNull java.lang.Iterable<? extends U> that, java.util.function.BiFunction<? super T,? super U,? extends R> mapper)
default Stream<Tuple2<T,java.lang.Integer>>	Stream.zipWithIndex()
default <U> Stream<U>	Stream.zipWithIndex(@NonNull java.util.function.BiFunction<? super T,? super java.lang.Integer,? extends U> mapper)

Methods in io.vavr.collection that return types with arguments of type Stream

Modifier and Type	Method	Description
static <T> Stream<Stream<T>>	StreamModule.Combinations.apply(Stream<T> elements, int k)
static <T> java.util.stream.Collector<T,java.util.ArrayList<T>,Stream<T>>	Stream.collector()	Returns a Collector which may be used in conjunction with Stream.collect(java.util.stream.Collector) to obtain a Stream.
default Stream<Stream<T>>	Stream.combinations()
default Stream<Stream<T>>	Stream.combinations(int k)
default Iterator<Stream<T>>	Stream.crossProduct(int power)
default <C> Map<C,Stream<T>>	Stream.groupBy(@NonNull java.util.function.Function<? super T,? extends C> classifier)
default Iterator<Stream<T>>	Stream.grouped(int size)
default Option<Stream<T>>	Stream.initOption()
default Tuple2<Stream<T>,Stream<T>>	Stream.partition(@NonNull java.util.function.Predicate<? super T> predicate)
default Tuple2<Stream<T>,Stream<T>>	Stream.partition(@NonNull java.util.function.Predicate<? super T> predicate)
default Stream<Stream<T>>	Stream.permutations()
default Iterator<Stream<T>>	Stream.slideBy(@NonNull java.util.function.Function<? super T,?> classifier)
default Iterator<Stream<T>>	Stream.sliding(int size)
default Iterator<Stream<T>>	Stream.sliding(int size, int step)
default Tuple2<Stream<T>,Stream<T>>	Stream.span(@NonNull java.util.function.Predicate<? super T> predicate)
default Tuple2<Stream<T>,Stream<T>>	Stream.span(@NonNull java.util.function.Predicate<? super T> predicate)
default Tuple2<Stream<T>,Stream<T>>	Stream.splitAt(int n)
default Tuple2<Stream<T>,Stream<T>>	Stream.splitAt(int n)
default Tuple2<Stream<T>,Stream<T>>	Stream.splitAt(@NonNull java.util.function.Predicate<? super T> predicate)
default Tuple2<Stream<T>,Stream<T>>	Stream.splitAt(@NonNull java.util.function.Predicate<? super T> predicate)
default Tuple2<Stream<T>,Stream<T>>	Stream.splitAtInclusive(@NonNull java.util.function.Predicate<? super T> predicate)
default Tuple2<Stream<T>,Stream<T>>	Stream.splitAtInclusive(@NonNull java.util.function.Predicate<? super T> predicate)
default Option<Stream<T>>	Stream.tailOption()
static <T> Stream<Stream<T>>	Stream.transpose(@NonNull Stream<Stream<T>> matrix)	Transposes the rows and columns of a Stream matrix.
default <T1,T2> Tuple2<Stream<T1>,Stream<T2>>	Stream.unzip(@NonNull java.util.function.Function<? super T,Tuple2<? extends T1,? extends T2>> unzipper)
default <T1,T2> Tuple2<Stream<T1>,Stream<T2>>	Stream.unzip(@NonNull java.util.function.Function<? super T,Tuple2<? extends T1,? extends T2>> unzipper)
default <T1,T2,T3> Tuple3<Stream<T1>,Stream<T2>,Stream<T3>>	Stream.unzip3(@NonNull java.util.function.Function<? super T,Tuple3<? extends T1,? extends T2,? extends T3>> unzipper)
default <T1,T2,T3> Tuple3<Stream<T1>,Stream<T2>,Stream<T3>>	Stream.unzip3(@NonNull java.util.function.Function<? super T,Tuple3<? extends T1,? extends T2,? extends T3>> unzipper)
default <T1,T2,T3> Tuple3<Stream<T1>,Stream<T2>,Stream<T3>>	Stream.unzip3(@NonNull java.util.function.Function<? super T,Tuple3<? extends T1,? extends T2,? extends T3>> unzipper)

Methods in io.vavr.collection with parameters of type Stream

Modifier and Type	Method	Description
static <T> Stream<Stream<T>>	StreamModule.Combinations.apply(Stream<T> elements, int k)
static <T> Stream<T>	StreamModule.DropRight.apply(List<T> front, List<T> rear, Stream<T> remaining)
static <T> Stream<T>	Stream.narrow(Stream<? extends T> stream)	Narrows a widened Stream<? extends T> to Stream<T> by performing a type-safe cast.
static <T> Stream<Stream<T>>	Stream.transpose(@NonNull Stream<Stream<T>> matrix)	Transposes the rows and columns of a Stream matrix.

Method parameters in io.vavr.collection with type arguments of type Stream

Modifier and Type	Method	Description
private Stream.Cons<T>	StreamModule.AppendSelf.appendAll(Stream.Cons<T> stream, java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)
private Stream.Cons<T>	StreamModule.AppendSelf.appendAll(Stream.Cons<T> stream, java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)
default Stream<T>	Stream.appendSelf(@NonNull java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)	Appends itself to the end of stream with mapper function.
default Stream<T>	Stream.appendSelf(@NonNull java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)	Appends itself to the end of stream with mapper function.
static <T> Stream<T>	Stream.cons(T head, @NonNull java.util.function.Supplier<? extends Stream<? extends T>> tailSupplier)	Constructs a Stream of a head element and a tail supplier.
default <U> U	Stream.transform(@NonNull java.util.function.Function<? super Stream<T>,? extends U> f)	Transforms this Stream.
static <T> Stream<Stream<T>>	Stream.transpose(@NonNull Stream<Stream<T>> matrix)	Transposes the rows and columns of a Stream matrix.

Constructor parameters in io.vavr.collection with type arguments of type Stream

Constructor	Description
AppendElements(T head, Queue<T> queue, java.util.function.Supplier<Stream<T>> tail)
AppendSelf(Stream.Cons<T> self, java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)
AppendSelf(Stream.Cons<T> self, java.util.function.Function<? super Stream<T>,? extends Stream<T>> mapper)
Cons(T head, java.util.function.Supplier<Stream<T>> tail)
ConsImpl(T head, java.util.function.Supplier<Stream<T>> tail)