com.aol.cyclops.javaslang.streams

Class BaseHotStreamImpl<T>

java.lang.Object

com.aol.cyclops.streams.IteratorHotStream<T>

com.aol.cyclops.javaslang.streams.BaseHotStreamImpl<T>

All Implemented Interfaces:

JavaslangHotStream<T>

Direct Known Subclasses:

NonPausableHotStream, PausableHotStreamImpl

public abstract class BaseHotStreamImpl<T>
extends com.aol.cyclops.streams.IteratorHotStream<T>
implements JavaslangHotStream<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected javaslang.collection.Stream<T>	stream

Fields inherited from class com.aol.cyclops.streams.IteratorHotStream

connected, connections, open, pause

Constructor Summary

Constructors

Constructor and Description
BaseHotStreamImpl(javaslang.collection.Stream<T> stream)

Method Summary

Modifier and Type	Method and Description
javaslang.collection.Stream<T>	connect()
javaslang.collection.Stream<T>	connect(java.util.Queue<T> queue)
<R extends javaslang.collection.Stream<T>> R	connectTo(java.util.Queue<T> queue, java.util.function.Function<javaslang.collection.Stream<T>,R> to)
abstract JavaslangHotStream<T>	init(java.util.concurrent.Executor exec)
JavaslangHotStream<T>	paused(java.util.concurrent.Executor exec)
JavaslangHotStream<T>	schedule(java.lang.String cron, java.util.concurrent.ScheduledExecutorService ex)
JavaslangHotStream<T>	scheduleFixedDelay(long delay, java.util.concurrent.ScheduledExecutorService ex)
JavaslangHotStream<T>	scheduleFixedRate(long rate, java.util.concurrent.ScheduledExecutorService ex)

Methods inherited from class com.aol.cyclops.streams.IteratorHotStream

isPaused, pause, scheduleFixedDelayInternal, scheduleFixedRate, scheduleInternal, unpause

Methods inherited from class java.lang.Object

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

Field Detail

stream

protected final javaslang.collection.Stream<T> stream

Constructor Detail

BaseHotStreamImpl

public BaseHotStreamImpl(javaslang.collection.Stream<T> stream)

Method Detail

paused

public JavaslangHotStream<T> paused(java.util.concurrent.Executor exec)

init

public abstract JavaslangHotStream<T> init(java.util.concurrent.Executor exec)

schedule

public JavaslangHotStream<T> schedule(java.lang.String cron,
                                      java.util.concurrent.ScheduledExecutorService ex)

scheduleFixedDelay

public JavaslangHotStream<T> scheduleFixedDelay(long delay,
                                                java.util.concurrent.ScheduledExecutorService ex)

scheduleFixedRate

public JavaslangHotStream<T> scheduleFixedRate(long rate,
                                               java.util.concurrent.ScheduledExecutorService ex)

connect

public javaslang.collection.Stream<T> connect()

Specified by:

connect in interface JavaslangHotStream<T>

connect

public javaslang.collection.Stream<T> connect(java.util.Queue<T> queue)

Specified by:

connect in interface JavaslangHotStream<T>

connectTo

public <R extends javaslang.collection.Stream<T>> R connectTo(java.util.Queue<T> queue,
                                                              java.util.function.Function<javaslang.collection.Stream<T>,R> to)

Specified by:

connectTo in interface JavaslangHotStream<T>