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 Stream.empty()
static <T> Stream<T>	API.Stream(T element)	Alias for Stream.of(Object)
static <T> Stream<T>	API.Stream(T @NonNull ... elements)	Alias for Stream.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 final class	Stream.Empty<T>	The empty Stream.
static final class	StreamModule.AppendElements<T>
static final class	StreamModule.ConsImpl<T>

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

Modifier and Type	Field	Description
private Supplier<Stream<T>>	StreamModule.StreamIterator.current
(package private) final 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 Iterable<? extends T> elements)
Stream<T>	StreamModule.AppendElements.appendAll(@NonNull Iterable<? extends T> elements)
default Stream<T>	Stream.appendSelf(@NonNull 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 Consumer<? super List<T>> action)
default Stream<T>	Stream.asJavaMutable(@NonNull Consumer<? super 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 Iterable<? extends 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 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 Supplier<? extends Stream<? extends T>> tailSupplier)	Constructs a Stream of a head element and a tail supplier.
static <T> Stream<T>	Stream.continually(@NonNull 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(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 Comparator<? super T> comparator)
default <U> Stream<T>	Stream.distinctBy(@NonNull Function<? super T, ? extends U> keyExtractor)
default Stream<T>	Stream.distinctByKeepLast(@NonNull Comparator<? super T> comparator)
default <U> Stream<T>	Stream.distinctByKeepLast(@NonNull 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 Predicate<? super T> predicate)
default Stream<T>	Stream.dropRightWhile(@NonNull Predicate<? super T> predicate)
default Stream<T>	Stream.dropUntil(@NonNull Predicate<? super T> predicate)
default Stream<T>	Stream.dropWhile(@NonNull Predicate<? super T> predicate)
static <T> Stream<T>	Stream.empty()	Returns the single instance of Empty.
default Stream<T>	Stream.extend(@NonNull 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 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 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 Predicate<? super T> predicate)
default <U> Stream<U>	Stream.flatMap(@NonNull Function<? super T, ? extends Iterable<? extends U>> mapper)
static Stream<Integer>	Stream.from(int value)	Returns an infinitely long Stream of int values starting from from.
static Stream<Integer>	Stream.from(int value, int step)	Returns an infinite long Stream of int values starting from value and spaced by step.
static Stream<Long>	Stream.from(long value)	Returns an infinitely long Stream of long values starting from from.
static Stream<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 Iterable<? extends T> elements)
default Stream<T>	Stream.intersperse(T element)
static <T> Stream<T>	Stream.iterate(@NonNull 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 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 Function<? super T, ? extends U> mapper)
default <U> Stream<U>	Stream.mapTo(U value)
default Stream<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<Boolean>	Stream.ofAll(boolean @NonNull ... elements)	Creates a Stream from boolean values.
static Stream<Byte>	Stream.ofAll(byte @NonNull ... elements)	Creates a Stream from byte values.
static Stream<Character>	Stream.ofAll(char @NonNull ... elements)	Creates a Stream from char values.
static Stream<Double>	Stream.ofAll(double @NonNull ... elements)	Creates a Stream values double values.
static Stream<Float>	Stream.ofAll(float @NonNull ... elements)	Creates a Stream from float values.
static Stream<Integer>	Stream.ofAll(int @NonNull ... elements)	Creates a Stream from int values.
static Stream<Long>	Stream.ofAll(long @NonNull ... elements)	Creates a Stream from long values.
static Stream<Short>	Stream.ofAll(short @NonNull ... elements)	Creates a Stream from short values.
static <T> Stream<T>	Stream.ofAll(@NonNull Iterable<? extends T> elements)	Creates a Stream of the given elements.
static <T> Stream<T>	Stream.ofAll(@NonNull Stream<? extends T> javaStream)	Creates a Stream that contains the elements of the given Stream.
default Stream<T>	Stream.orElse(@NonNull Iterable<? extends T> other)
default Stream<T>	Stream.orElse(@NonNull Supplier<? extends Iterable<? extends T>> supplier)
default Stream<T>	Stream.padTo(int length, T element)
default Stream<T>	Stream.patch(int from, @NonNull Iterable<? extends T> that, int replaced)
default Stream<T>	Stream.peek(@NonNull Consumer<? super T> action)
default Stream<Stream<T>>	Stream.permutations()
default Stream<T>	Stream.prepend(T element)
default Stream<T>	Stream.prependAll(@NonNull Iterable<? extends T> elements)
static Stream<Character>	Stream.range(char from, char toExclusive)	Creates a Stream of char numbers starting from from, extending to toExclusive - 1.
static Stream<Integer>	Stream.range(int from, int toExclusive)	Creates a Stream of int numbers starting from from, extending to toExclusive - 1.
static Stream<Long>	Stream.range(long from, long toExclusive)	Creates a Stream of long numbers starting from from, extending to toExclusive - 1.
static Stream<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<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<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<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<Character>	Stream.rangeClosed(char from, char toInclusive)	Creates a Stream of char numbers starting from from, extending to toInclusive.
static Stream<Integer>	Stream.rangeClosed(int from, int toInclusive)	Creates a Stream of int numbers starting from from, extending to toInclusive.
static Stream<Long>	Stream.rangeClosed(long from, long toInclusive)	Creates a Stream of long numbers starting from from, extending to toInclusive.
static Stream<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<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<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<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 Predicate<? super T> predicate)
default Stream<T>	Stream.remove(T element)
default Stream<T>	Stream.removeAll(@NonNull Iterable<? extends T> elements)
default Stream<T>	Stream.removeAll(@NonNull 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 Predicate<T> predicate)
default Stream<T>	Stream.removeLast(@NonNull 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 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 BiFunction<? super T, ? super T, ? extends T> operation)
default <U> Stream<U>	Stream.scanLeft(U zero, @NonNull BiFunction<? super U, ? super T, ? extends U> operation)
default <U> Stream<U>	Stream.scanRight(U zero, @NonNull 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 Comparator<? super U> comparator, Function<? super T, ? extends U> mapper)
default <U extends Comparable<? super U>> Stream<T>	Stream.sortBy(@NonNull Function<? super T, ? extends U> mapper)
default Stream<T>	Stream.sorted()
default Stream<T>	Stream.sorted(@NonNull 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 Function<? super 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 Predicate<? super T> predicate)
default Stream<T>	Stream.takeRightWhile(@NonNull Predicate<? super T> predicate)
default Stream<T>	Stream.takeUntil(@NonNull Predicate<? super T> predicate)
default Stream<T>	Stream.takeWhile(@NonNull 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 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 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 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 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 Iterable<? extends U> that)
default <U> Stream<Tuple2<T,U>>	Stream.zipAll(@NonNull Iterable<? extends U> iterable, T thisElem, U thatElem)
default <U,R> Stream<R>	Stream.zipWith(@NonNull Iterable<? extends U> that, BiFunction<? super T, ? super U, ? extends R> mapper)
default Stream<Tuple2<T,Integer>>	Stream.zipWithIndex()
default <U> Stream<U>	Stream.zipWithIndex(@NonNull BiFunction<? super T, ? super 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> Collector<T, 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 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 Predicate<? super T> predicate)
default Tuple2<Stream<T>, Stream<T>>	Stream.partition(@NonNull Predicate<? super T> predicate)
default Stream<Stream<T>>	Stream.permutations()
default Iterator<Stream<T>>	Stream.slideBy(@NonNull 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 Predicate<? super T> predicate)
default Tuple2<Stream<T>, Stream<T>>	Stream.span(@NonNull 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 Predicate<? super T> predicate)
default Tuple2<Stream<T>, Stream<T>>	Stream.splitAt(@NonNull Predicate<? super T> predicate)
default Tuple2<Stream<T>, Stream<T>>	Stream.splitAtInclusive(@NonNull Predicate<? super T> predicate)
default Tuple2<Stream<T>, Stream<T>>	Stream.splitAtInclusive(@NonNull 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 Function<? super T, Tuple2<? extends T1, ? extends T2>> unzipper)
default <T1,T2> Tuple2<Stream<T1>, Stream<T2>>	Stream.unzip(@NonNull Function<? super T, Tuple2<? extends T1, ? extends T2>> unzipper)
default <T1,T2,T3> Tuple3<Stream<T1>, Stream<T2>, Stream<T3>>	Stream.unzip3(@NonNull 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 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 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, Function<? super Stream<T>, ? extends Stream<T>> mapper)
private Stream.Cons<T>	StreamModule.AppendSelf.appendAll(Stream.Cons<T> stream, Function<? super Stream<T>, ? extends Stream<T>> mapper)
default Stream<T>	Stream.appendSelf(@NonNull Function<? super Stream<T>, ? extends Stream<T>> mapper)	Appends itself to the end of stream with mapper function.
default Stream<T>	Stream.appendSelf(@NonNull 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 Supplier<? extends Stream<? extends T>> tailSupplier)	Constructs a Stream of a head element and a tail supplier.
default <U> U	Stream.transform(@NonNull 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

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