public abstract class AbstractLocalCacheStream<T,S extends BaseStream<T,S>> extends Object implements BaseStream<T,S>
Modifier and Type | Class and Description |
---|---|
static interface |
AbstractLocalCacheStream.StreamSupplier<R> |
Modifier and Type | Field and Description |
---|---|
protected Queue<IntermediateOperation> |
intermediateOperations |
protected Set<?> |
keysToFilter |
protected Log |
log |
protected Collection<Runnable> |
onCloseRunnables |
protected boolean |
parallel |
protected ComponentRegistry |
registry |
protected Set<Integer> |
segmentsToFilter |
protected AbstractLocalCacheStream.StreamSupplier<T> |
streamSupplier |
Constructor and Description |
---|
AbstractLocalCacheStream(AbstractLocalCacheStream.StreamSupplier<T> streamSupplier,
boolean parallel,
ComponentRegistry registry) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected S |
createStream() |
boolean |
isParallel() |
S |
onClose(Runnable closeHandler) |
S |
parallel() |
S |
sequential() |
S |
unordered() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
iterator, spliterator
protected final Log log
protected final AbstractLocalCacheStream.StreamSupplier<T> streamSupplier
protected final ComponentRegistry registry
protected final Collection<Runnable> onCloseRunnables
protected final Queue<IntermediateOperation> intermediateOperations
protected Set<?> keysToFilter
protected boolean parallel
public AbstractLocalCacheStream(AbstractLocalCacheStream.StreamSupplier<T> streamSupplier, boolean parallel, ComponentRegistry registry)
streamSupplier
- parallel
- registry
- protected final S createStream()
public boolean isParallel()
isParallel
in interface BaseStream<T,S extends BaseStream<T,S>>
public S sequential()
sequential
in interface BaseStream<T,S extends BaseStream<T,S>>
public S parallel()
parallel
in interface BaseStream<T,S extends BaseStream<T,S>>
public S unordered()
unordered
in interface BaseStream<T,S extends BaseStream<T,S>>
public S onClose(Runnable closeHandler)
onClose
in interface BaseStream<T,S extends BaseStream<T,S>>
public void close()
close
in interface AutoCloseable
close
in interface BaseStream<T,S extends BaseStream<T,S>>
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.