com.aol.cyclops.javaslang.streams

Interface JavaslangHotStream<T>

All Known Implementing Classes:

HotStreamImpl

public interface JavaslangHotStream<T>

Method Summary

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)

Method Detail

connect

<any> connect()

connect

<any> connect(java.util.Queue<T> queue)

connectTo

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