diff --git a/src/repositories/UnoptimizedInMemoryRepository.ts b/src/repositories/UnoptimizedInMemoryRepository.ts index a888dab..e4addc1 100644 --- a/src/repositories/UnoptimizedInMemoryRepository.ts +++ b/src/repositories/UnoptimizedInMemoryRepository.ts @@ -152,7 +152,10 @@ export class UnoptimizedInMemoryRepository implements GetterSetterRepository { } else { this.etas.push(eta); } + this.publishEtaUpdateToSubscribers(eta); + } + private publishEtaUpdateToSubscribers(eta: IEta) { this.subscribers.forEach(subscriber => { subscriber(eta); });