BaseHotStreamImpl (cyclops-reactor 8.4.2 API)

java.lang.Object
- com.aol.cyclops.internal.stream.IteratorHotStream<T>
- - com.aol.cyclops.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.cyclops.internal.stream.IteratorHotStream
  connected, connections, open, pause

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

Constructor Summary

Constructors
Constructor and Description

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

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

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
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.cyclops.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.cyclops.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 apply backpressure to the HotStream if it produces data faster than the connected Stream can consume it 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

Class BaseHotStreamImpl<T>

Field Summary

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

Constructor Summary