public class HotStreamImpl<T> extends java.lang.Object implements JavaslangHotStream<T>
| Constructor and Description |
|---|
HotStreamImpl(<any> stream) |
| Modifier and Type | Method and Description |
|---|---|
<any> |
connect() |
<any> |
connect(java.util.Queue<T> queue) |
<R extends <any>> |
connectTo(java.util.Queue<T> queue,
java.util.function.Function<<any>,R> to) |
JavaslangHotStream<T> |
init(java.util.concurrent.Executor exec) |
public JavaslangHotStream<T> init(java.util.concurrent.Executor exec)
public <any> connect()
connect in interface JavaslangHotStream<T>public <any> connect(java.util.Queue<T> queue)
connect in interface JavaslangHotStream<T>public <R extends <any>> R connectTo(java.util.Queue<T> queue, java.util.function.Function<<any>,R> to)
connectTo in interface JavaslangHotStream<T>