com.aol.cyclops.types.stream

Interface PausableHotStream<T>

Type Parameters:

T - Data type of elements in the Stream

All Superinterfaces:

HotStream<T>

All Known Implementing Classes:

PausableHotStreamImpl

public interface PausableHotStream<T>
extends HotStream<T>

A HotStream (Stream already emitting data) that can be paused and unpaused

Method Summary

Modifier and Type	Method and Description
void	pause() Pause this HotStream (stop it producing data until unpaused)
void	unpause() Unpause this HotStream (restart data production)

Methods inherited from interface com.aol.cyclops.types.stream.HotStream

connect, connect, connectTo

Method Detail

unpause

void unpause()

Unpause this HotStream (restart data production)

pause

void pause()

Pause this HotStream (stop it producing data until unpaused)