public interface PausableJavaslangHotStream<T> extends JavaslangHotStream<T>
void
pause()
unpause()
connect, connect, connectTo
void unpause()
void pause()