Добавлен Subject RxJS для подписки на изменения задач

This commit is contained in:
Pavel Gnedov 2022-06-17 10:42:58 +07:00
parent a5e41f7f19
commit 3120b3a0a6

View file

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