com.aol.cyclops.javaslang.streams

Class HotStreamImpl<T>

java.lang.Object

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

All Implemented Interfaces:

JavaslangHotStream<T>

public class HotStreamImpl<T>
extends java.lang.Object
implements JavaslangHotStream<T>

Constructor Summary

Constructors

Constructor and Description
HotStreamImpl(<any> stream)

Method Summary

Modifier and Type	Method and Description
<any>	connect()
<any>	connect(java.util.Queue<T> queue)
<R extends <any>> R	connectTo(java.util.Queue<T> queue, java.util.function.Function<<any>,R> to)
JavaslangHotStream<T>	init(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 java.lang.Object

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

Constructor Detail

HotStreamImpl

public HotStreamImpl(<any> stream)

Method Detail

init

public 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 <any> connect()

Specified by:

connect in interface JavaslangHotStream<T>

connect

public <any> connect(java.util.Queue<T> queue)

Specified by:

connect in interface JavaslangHotStream<T>

connectTo

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

Specified by:

connectTo in interface JavaslangHotStream<T>