org.ujorm.tools.common

Class StreamUtils

java.lang.Object

org.ujorm.tools.common.StreamUtils

public abstract class StreamUtils
extends Object

Static methods

Method Summary

Modifier and Type	Method and Description
static <T> Collector<T,?,ArrayDeque<T>>	collectToDequeue() A stream collecetor to a ArrayDeque type
static Stream<String>	rowsOfUrl(URL url) Returns a stream of lines form URL resource
static <D,R> Joinable<D,R>	toJoinable(Function<D,R> fce) Create a joinable function Usage Function<Person, String> nameProvider = Joinable .of (Person::getBoss) .add(Person::getBoss) .add(Person::getName); String superBossName = nameProvider.apply(getPerson());
static <T> Stream<T>	toStream(Iterator<T> iterator) Convert an interator to a Stream
static <T> Stream<T>	toStream(Iterator<T> iterator, boolean parallel) Convert an interator to a Stream

Methods inherited from class java.lang.Object

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

Method Detail

rowsOfUrl

public static Stream<String> rowsOfUrl(@Nonnull
                                       URL url)
                                throws IOException

Returns a stream of lines form URL resource

Parameters:

url - An URL link to a resource

Returns:

The customer is responsible for closing the stream. During closing, an IllegalStateException may occur due to an IOException.

Throws:

IOException

toStream

public static <T> Stream<T> toStream(@Nonnull
                                     Iterator<T> iterator)

Convert an interator to a Stream

Type Parameters:

T - An item type

Parameters:

iterator - Source iterator

Returns:

toStream

public static <T> Stream<T> toStream(@Nonnull
                                     Iterator<T> iterator,
                                     boolean parallel)

Convert an interator to a Stream

Type Parameters:

T - An item type

Parameters:

iterator - Source iterator

parallel - Parrallell processing is enabled

Returns:

collectToDequeue

@Nonnull
public static <T> Collector<T,?,ArrayDeque<T>> collectToDequeue()

A stream collecetor to a ArrayDeque type

toJoinable

@Nonnull
public static <D,R> Joinable<D,R> toJoinable(@Nonnull
                                                      Function<D,R> fce)

Create a joinable function

Usage

  Function<Person, String> nameProvider = Joinable
     .of (Person::getBoss)
     .add(Person::getBoss)
     .add(Person::getName);
  String superBossName = nameProvider.apply(getPerson());
 

Type Parameters:

D - Domain value

R - Result value

Parameters:

fce - An original function

Returns:

The new object type of Function