RocketData: DataProviders don't call delegate for update after first miss?

Hey, thanks for a great library. I was trying to integrate it into my project. I use a wrapper ReactiveProvider<T> around DataProvider<T> for RAC Support. I have my ReactiveProviders in each viewModel, but networking is done elsewhere so I initiate another DataProvider and call setData(_:updateCache:context:) on that data provider, and the ReactiveProvider doesn’t get the delegate call for update.

Is this expected behaviour? I saw another issue, is this related to that? https://github.com/linkedin/RocketData/issues/8

Here is the code for ReactiveProvider

class ReactiveProvider<M: SimpleModel> {
    private let provider = DataProvider<M>()

    let signal: Signal<M?, NoError>
    fileprivate let pipe: Observer<M?, NoError>

    init() {
        let (signal, pipe) = Signal<M?, NoError>.pipe()
        self.signal = signal
        self.pipe = pipe
        provider.delegate = self
    }

    func start(with cacheKey: CacheKey) {
        if provider.isPaused {
            provider.isPaused = false
        }
        provider.fetchDataFromCache(withCacheKey: cacheKey.key, context: cacheKey) {
            [weak self] model, error in
            self?.pipe.send(value: model)
        }
    }

    func pause() {
        provider.isPaused = true
    }
}

extension ReactiveProvider: DataProviderDelegate {
    func dataProviderHasUpdatedData<T>(_ dataProvider: DataProvider<T>,
                                    context: Any?) {
        guard let data = dataProvider.data as? M else {
            pipe.send(value: nil)
            return
        }

        pipe.send(value: data)
    }
}

and here is the code that sets the data (in networking part of the app, not in viewModel)

class CacheProvider {
    private var providers: [String: Any] = [:]

    func cache<T: SimpleModel>(object: T?, for key: CacheKey) {
        let provider: DataProvider<T>
        if let p = providers[key.key] as? DataProvider<T> {
            provider = p
        } else {
            provider = DataProvider<T>()
            providers[key.key] = provider
        }
        provider.setData(object, updateCache: true, context: key)
    }
}