Package org.apache.jena.atlas.lib

Class StreamOps

java.lang.Object

org.apache.jena.atlas.lib.StreamOps

public class StreamOps
extends java.lang.Object

Collect some stream operations into one place. Sometimes, the function form reads better.

See Also:

Iter - a stream-like class for iterators.

Constructor Summary

Constructors

Constructor	Description
StreamOps()

Method Summary

Modifier and Type	Method	Description
static <X> java.util.stream.Stream<X>	debug(java.util.stream.Stream<X> stream)	Print immediate, noting empty streams
static <X> X	element(java.util.Collection<X> collection)	An element from a Collection
static <X> X	first(java.util.stream.Stream<X> stream)	First element or null
static <X> java.util.stream.Stream<X>	print(java.io.PrintStream out, java.lang.String leader, java.util.stream.Stream<X> stream)
static <X> java.util.stream.Stream<X>	print(java.io.PrintStream out, java.util.stream.Stream<X> stream)
static <X> java.util.stream.Stream<X>	print(java.util.stream.Stream<X> stream)	Debug : print stream.
static <X> java.util.stream.Stream<X>	stream(java.util.Iterator<X> iter)	Iterator to Stream.
static <X> java.util.List<X>	toList(java.util.stream.Stream<X> stream)	Stream to List
static <X> java.util.Set<X>	toSet(java.util.stream.Stream<X> stream)	Stream to Set

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamOps

public StreamOps()

Method Detail

stream

public static <X> java.util.stream.Stream<X> stream(java.util.Iterator<X> iter)

Iterator to Stream. Call to Iter.asStream(java.util.Iterator<T>).

toList

public static <X> java.util.List<X> toList(java.util.stream.Stream<X> stream)

Stream to List

toSet

public static <X> java.util.Set<X> toSet(java.util.stream.Stream<X> stream)

Stream to Set

first

public static <X> X first(java.util.stream.Stream<X> stream)

First element or null

element

public static <X> X element(java.util.Collection<X> collection)

An element from a Collection

print

public static <X> java.util.stream.Stream<X> print(java.util.stream.Stream<X> stream)

Debug : print stream. This operation prints the whole stream at the point it is used, and then returns a new stream of the same elements.

print

public static <X> java.util.stream.Stream<X> print(java.io.PrintStream out,
                                                   java.util.stream.Stream<X> stream)

print

public static <X> java.util.stream.Stream<X> print(java.io.PrintStream out,
                                                   java.lang.String leader,
                                                   java.util.stream.Stream<X> stream)

debug

public static <X> java.util.stream.Stream<X> debug(java.util.stream.Stream<X> stream)

Print immediate, noting empty streams