diff --git a/src/repositories/UnoptimizedInMemoryRepository.ts b/src/repositories/UnoptimizedInMemoryRepository.ts index 203dde2..a888dab 100644 --- a/src/repositories/UnoptimizedInMemoryRepository.ts +++ b/src/repositories/UnoptimizedInMemoryRepository.ts @@ -152,6 +152,10 @@ export class UnoptimizedInMemoryRepository implements GetterSetterRepository { } else { this.etas.push(eta); } + + this.subscribers.forEach(subscriber => { + subscriber(eta); + }); } private async removeEntityByMatcherIfExists(callback: (value: T) => boolean, arrayToSearchIn: T[]) {