From 3120b3a0a6aa362b667fce5f3e132beb0ef92ddb Mon Sep 17 00:00:00 2001
From: Pavel Gnedov <pavel@gnedov.info>
Date: Fri, 17 Jun 2022 10:42:58 +0700
Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5?=
 =?UTF-8?q?=D0=BD=20Subject=20RxJS=20=D0=B4=D0=BB=D1=8F=20=D0=BF=D0=BE?=
 =?UTF-8?q?=D0=B4=D0=BF=D0=B8=D1=81=D0=BA=D0=B8=20=D0=BD=D0=B0=20=D0=B8?=
 =?UTF-8?q?=D0=B7=D0=BC=D0=B5=D0=BD=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=B7=D0=B0?=
 =?UTF-8?q?=D0=B4=D0=B0=D1=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/redmine-issues-cache-writer.service.ts                | 4 ++++
 1 file changed, 4 insertions(+)

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;
   }