com.aol.cyclops2.internal.stream

Class BaseHotStreamImpl<T>

java.lang.Object

com.aol.cyclops2.internal.stream.IteratorHotStream<T>

com.aol.cyclops2.internal.stream.BaseHotStreamImpl<T>

All Implemented Interfaces:

HotStream<T>

Direct Known Subclasses:

NonPausableHotStream, PausableHotStreamImpl

public abstract class BaseHotStreamImpl<T>
extends IteratorHotStream<T>
implements HotStream<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.stream.Stream<T>	stream

Fields inherited from class com.aol.cyclops2.internal.stream.IteratorHotStream

connected, connections, open, pause

Constructor Summary

Constructors

Constructor and Description
BaseHotStreamImpl(java.util.stream.Stream<T> stream)

Method Summary

Modifier and Type	Method and Description
ReactiveSeq<T>	connect(java.util.Queue<T> queue) Connect to this HotStream using the provided transfer async.Queue.
abstract HotStream<T>	init(java.util.concurrent.Executor exec)
HotStream<T>	paused(java.util.concurrent.Executor exec)
HotStream<T>	schedule(java.lang.String cron, java.util.concurrent.ScheduledExecutorService ex)
HotStream<T>	scheduleFixedDelay(long delay, java.util.concurrent.ScheduledExecutorService ex)
HotStream<T>	scheduleFixedRate(long rate, java.util.concurrent.ScheduledExecutorService ex)

Methods inherited from class com.aol.cyclops2.internal.stream.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

Methods inherited from interface com.aol.cyclops2.types.stream.HotStream

connect, connectTo

Field Detail

stream

protected final java.util.stream.Stream<T> stream

Constructor Detail

BaseHotStreamImpl

public BaseHotStreamImpl(java.util.stream.Stream<T> stream)

Method Detail

paused

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

init

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

schedule

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

scheduleFixedDelay

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

scheduleFixedRate

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

connect

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

Description copied from interface: HotStream

Connect to this HotStream using the provided transfer async.Queue. The transfer Queue can be used to applyHKT backpressure to the HotStream if it produces data faster than the connected Stream can consume it cyclops2.async.wait.WaitStrategy

  
 new LazyReact().range(0,Integer.MAX_VALUE)
                .limit(1000)
                .peek(v->value=v)
                .peek(v->latch.countDown())
                .hotStream(exec)
                .connect(new LinkedBlockingQueue<>())
                .limit(100)
                .futureOperations(ForkJoinPool.commonPool())
                .forEach(System.out::println)
 
 
 
 
 

Specified by:

connect in interface HotStream<T>

Parameters:

queue - Transfer Queue between the Streams

Returns:

Stream connected to the HotStream emitting data