StreamState
constructor(id: StreamIdentifier, feeds: Set<Feed>, state: AtomicReference<StreamStatusManager.State> = AtomicReference(State.PENDING), stoppedFeeds: ConcurrentHashSet<Feed> = ConcurrentHashSet(), numStoppedFeeds: AtomicInteger = AtomicInteger())