StreamState
data class StreamState(val id: StreamIdentifier, val feeds: Set<Feed>, val state: AtomicReference<StreamStatusManager.State> = AtomicReference(State.PENDING), val stoppedFeeds: ConcurrentHashSet<Feed> = ConcurrentHashSet(), val numStoppedFeeds: AtomicInteger = AtomicInteger())
Constructors
Link copied to clipboard
constructor(id: StreamIdentifier, feeds: Set<Feed>, state: AtomicReference<StreamStatusManager.State> = AtomicReference(State.PENDING), stoppedFeeds: ConcurrentHashSet<Feed> = ConcurrentHashSet(), numStoppedFeeds: AtomicInteger = AtomicInteger())