Update API to use ObservableConcurrentDictionary