У меня проблема с наблюдаемой подпиской. У меня есть NotificationService
, который я использую для передачи данных из ответа любого компонента в NotificationComponent
. И теперь мне нужно получить ответ от подписки только один раз, а я получаю дважды.
Вот мой NotificationService:
export class NotificationSharedService {
private emitChangeSource = new Subject<any>();
changeEmitted = this.emitChangeSource.asObservable();
emitChange(change: any) {
console.log(change);
this.emitChangeSource.next(change);
}
getData(): Observable<any> {
return this.changeEmitted;
}
}
Отсюда я отправляю текущий статус для NotificationComponent
:
const setDefaultImageRequest = this.images.defaultImage(id_image)
.map((data: ResponseService) => {
return Image.createFromObject(data.data);
})
.subscribe((data) => {
console.log(data);
this.defaultImage.id = data.id;
this.propertyGalleryStatus = true;
const status = {
'message': 'Изображение по-умолчанию установлено успешно',
'status': true
};
this.notificationShared.emitChange(status);
}, (errors) => {
console.log(errors);
this.propertyGalleryStatus = true;
});
this.subscriptions.push(setDefaultImageRequest);
Вот мой NotificationComponent
, на который я подписан:
constructor(public sharedData: NotificationSharedService) {
const getSharedData = this.sharedData.getData().subscribe((data) => {
console.log(data);
this.status = false;
this.statusError = false;
this.state = true;
if (data.internet_connection !== undefined) {
if (!data.internet_connection) {
console.log(data);
this.message = this.messages.internet_error;
this.statusError = data.statusError;
console.log(this.message);
return;
}
}
this.message = data.message;
this.status = data.status;
this.statusError = data.statusError;
this.fadeNotification = setTimeout(() => {
this.state = false;
setTimeout(() => {
this.status = false;
}, 5000);
this.statusError = false;
}, 4000);
});
this.subscriptions.push(getSharedData);
}
Вот ответ, где подписка сработала дважды:
Вот скриншот, на котором шаблон уведомления срабатывает дважды:
Вот шаблон уведомления
<div on-mouseover="hoverNotification()" on-mouseout="unhoverNotification()" [ngClass]="{sbNotificationActive: state, sbNotificationSuccess: status, sbNotificationFailure: statusError}" class="sb-notification">
<div class="sb-notification__wrapper">
<div class="sb-notification__box">
<span class="sb-notification__message">{{message}}</span>
<a *ngIf="!linkStatus" role="button" (click)="reloadPage()" class="sb-notification__reload">Reload page</a>
</div>
<div (click)="close()" class="sb-notification__close-button">
<i class="sb-notification__icon flaticon-cancel"></i>
</div>
</div>