ДМ
await client.SendLoan
Size: a a a
2021 January 14
ДМ
Понял?
IS
нихуя не понял
ДМ
do_consume - это подписчик.
await sendloan - это провайдер.
do_consume в течении 2 секунд ждет ответа от sendloan
await sendloan - это провайдер.
do_consume в течении 2 секунд ждет ответа от sendloan
ДМ
Вот как мне этот ответ вытащить в ретерне функции do_consume
IS
у тебя тут ответ приходит?
ДМ
Выше
IS
да ну где выше-то
IS
Дмитрий Мачихелян
сам тут законсолил респонс
ДМ
IS
ну так и сказал бы
IS
return new Promise((resolve) => {
ch.consume(q, (message) => {
ch.ack(message);
ch.cancel('myconsumer');
resolve(message);
});
});
ch.consume(q, (message) => {
ch.ack(message);
ch.cancel('myconsumer');
resolve(message);
});
});
IS
примерно так
ДМ
проблема вт ом, что я должен еще закрывать соединение
ДМ
Там же таймаут ниже
IS
таймаут должен выбрасывать ошибку?
ДМ
Не
ДМ
Он проосто закрывает коннекты и всё.
IS
return Promise.race([
new Promise((resolve) => {
ch.consume(q, (message) => {
ch.ack(message);
ch.cancel('myconsumer');
resolve(message);
});
}),
new Promise((resolve) => {
setTimeout(
() => {
ch.close();
conn.close();
resolve('hello');
},
2000
)
})
]);
IS
что-то такое