HotStreamImpl (cyclops-javaslang 6.2.3 API)

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

Constructors
Constructor and Description
`HotStreamImpl(<any> stream)`

All Methods Instance Methods Concrete Methods
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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

Class HotStreamImpl<T>