PausableHotStreamImpl (cyclops-javaslang 7.3.0 API)

java.lang.Object
- com.aol.cyclops.streams.IteratorHotStream<T>
- - com.aol.cyclops.javaslang.streams.BaseHotStreamImpl<T>
  - - com.aol.cyclops.javaslang.streams.PausableHotStreamImpl<T>

All Implemented Interfaces:: JavaslangHotStream<T>, PausableJavaslangHotStream<T>

public class PausableHotStreamImpl<T>
extends BaseHotStreamImpl<T>
implements PausableJavaslangHotStream<T>

Field Summary
- Fields inherited from class com.aol.cyclops.javaslang.streams.BaseHotStreamImpl
  stream
- Fields inherited from class com.aol.cyclops.streams.IteratorHotStream
  connected, connections, open, pause

Constructors
Constructor and Description
`PausableHotStreamImpl(javaslang.collection.Stream<T> stream)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`PausableJavaslangHotStream<T>`	`init(java.util.concurrent.Executor exec)`
`void`	`pause()`
`PausableJavaslangHotStream<T>`	`paused(java.util.concurrent.Executor exec)`
`void`	`unpause()`

Methods inherited from class com.aol.cyclops.streams.IteratorHotStream
isPaused, scheduleFixedDelayInternal, scheduleFixedRate, scheduleInternal

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.javaslang.streams.JavaslangHotStream
connect, connect, connectTo

Class PausableHotStreamImpl<T>