com.aol.cyclops.javaslang.streams

Interface JavaslangHotStream<T>

All Known Subinterfaces:

PausableJavaslangHotStream<T>

All Known Implementing Classes:

BaseHotStreamImpl, NonPausableHotStream, PausableHotStreamImpl

public interface JavaslangHotStream<T>

Method Summary

Modifier and Type	Method and Description
javaslang.collection.Stream<T>	connect()
javaslang.collection.Stream<T>	connect(java.util.Queue<T> queue)
<R extends javaslang.collection.Stream<T>> R	connectTo(java.util.Queue<T> queue, java.util.function.Function<javaslang.collection.Stream<T>,R> to)

Method Detail

connect

javaslang.collection.Stream<T> connect()

connect

javaslang.collection.Stream<T> connect(java.util.Queue<T> queue)

connectTo

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