StateStore
constructor(stateWithCounts: MutableMap<K1, StateWithCounts<S>> = mutableMapOf(), streamCounts: MutableMap<DestinationStream.Descriptor, Long> = mutableMapOf(), streamsEnded: MutableSet<DestinationStream.Descriptor> = mutableSetOf())