Class StreamContext

java.lang.Object

one.util.streamex.StreamContext

class StreamContext
extends Object

This class controls stream execution mode (parallel/sequential), custom FJP and close handlers.

Fields are package-private and mutable, but it's forbidden to change them from outside this class.

For performance reasons shared objects SEQUENTIAL and PARALLEL are used: then have no custom FJP and no close handler. If custom FJP or close handler is requested for shared object, a new object is created, otherwise the current one is modified.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Runnable	closeHandler
(package private) ForkJoinPool	fjp
(package private) boolean	parallel
(package private) static final StreamContext	PARALLEL
(package private) static final StreamContext	SEQUENTIAL

Constructor Summary

Constructors

Modifier	Constructor	Description
private	StreamContext(boolean parallel)

Method Summary

Modifier and Type	Method	Description
(package private) void	close()
(package private) StreamContext	combine(BaseStream<?,?> other)
(package private) static Runnable	compose(Runnable r1, Runnable r2)
(package private) StreamContext	detach()
(package private) static StreamContext	of(BaseStream<?,?> stream)
(package private) StreamContext	onClose(Runnable r)
(package private) StreamContext	parallel()
(package private) StreamContext	parallel(ForkJoinPool fjp)
(package private) StreamContext	sequential()
(package private) <T> T	terminate(Supplier<T> terminalOperation)
(package private) <T,U> T	terminate(U value, Function<U,T> terminalOperation)

Methods inherited from class Object

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

Field Details

SEQUENTIAL

static final StreamContext SEQUENTIAL

PARALLEL

static final StreamContext PARALLEL

parallel

boolean parallel

fjp

ForkJoinPool fjp

closeHandler

Runnable closeHandler

Constructor Details

StreamContext

private StreamContext(boolean parallel)

Method Details

terminate

<T> T terminate(Supplier<T> terminalOperation)

terminate

<T,U> T terminate(U value,
 Function<U,T> terminalOperation)

parallel

StreamContext parallel()

sequential

StreamContext sequential()

parallel

StreamContext parallel(ForkJoinPool fjp)

detach

StreamContext detach()

onClose

StreamContext onClose(Runnable r)

close

void close()

compose

static Runnable compose(Runnable r1,
 Runnable r2)

combine

StreamContext combine(BaseStream<?,?> other)

of

static StreamContext of(BaseStream<?,?> stream)