diff --git a/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts b/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts
index d5bdaac..dcd4cb8 100644
--- a/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts
+++ b/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts
@@ -1,12 +1,15 @@
 import { Inject, Injectable, Logger } from '@nestjs/common';
 import { RedmineTypes } from 'libs/redmine-types';
 import nano from 'nano';
+import { Subject } from 'rxjs';
 import { SaveResponse } from './save-response';
 
 @Injectable()
 export class RedmineIssuesCacheWriterService {
   private logger = new Logger(RedmineIssuesCacheWriterService.name);
 
+  subject = new Subject<SaveResponse>();
+
   constructor(
     @Inject('ISSUE_DOCUMENT_SCOPE')
     private issueDbProvider: () => Promise<
@@ -47,6 +50,7 @@ export class RedmineIssuesCacheWriterService {
     this.logger.debug(
       `Saving issue success ${issue?.id || '-'} - ${issue?.subject || '-'}`,
     );
+    this.subject.next(res);
     return res;
   }