PS
Есть патерн сообщение, есть событие. Ну вот событие работает, а сообщение перестало напроч. Ну ни как его не заставить. emit работает (даже если принимающая сторона @MessegePattern). Жесть какая то. Все вроде уже сто раз перепроверил
Size: a a a
PS
PS
PS
VA
VA
PS
VA
VA
const serviceResponse = new Promise((resolve, reject) => {
this._pageService.send<T>('message__pattern', {})
.pipe(
timeout(300),
catchError(err => {
if (err instanceof TimeoutError) {
return throwError(new RequestTimeoutException());
}
return throwError(err);
})
)
.subscribe(
data => {
resolve(data);
},
error => {
reject(error);
}
);
});PS
const serviceResponse = new Promise((resolve, reject) => {
this._pageService.send<T>('message__pattern', {})
.pipe(
timeout(300),
catchError(err => {
if (err instanceof TimeoutError) {
return throwError(new RequestTimeoutException());
}
return throwError(err);
})
)
.subscribe(
data => {
resolve(data);
},
error => {
reject(error);
}
);
});VA
AK
const serviceResponse = new Promise((resolve, reject) => {
this._pageService.send<T>('message__pattern', {})
.pipe(
timeout(300),
catchError(err => {
if (err instanceof TimeoutError) {
return throwError(new RequestTimeoutException());
}
return throwError(err);
})
)
.subscribe(
data => {
resolve(data);
},
error => {
reject(error);
}
);
});DB
AK
VA
AK
this._pageService.send<T>('message__pattern', {})
.pipe(
timeout(300),
catchError(err => {
if (err instanceof TimeoutError) {
return throwError(new RequestTimeoutException());
}
return throwError(err);
})
)
.toPromise()VA
this._pageService.send<T>('message__pattern', {})
.pipe(
timeout(300),
catchError(err => {
if (err instanceof TimeoutError) {
return throwError(new RequestTimeoutException());
}
return throwError(err);
})
)
.toPromise()AK
YE
LK
И