2016-02-10 4 views
0

У меня есть цепочка обещаний, такая как внизу, у которой есть три обещания. Я немного изучил Rx.js, и я не могу понять, с чего начать, когда дело доходит до преобразования этих обещаний в наблюдаемые и объединения этой информации в разные функции. Я бы очень признателен за руководство или знания, если это возможно.От цепочки обещаний до Rx.js

export function pushCustomers (mongo, shopify) { 
    return getDocsWhereRequest(mongo, 'shopify_customers').map(customer => { 
    return createCustomer (shopify, customer.shopifyRequest).then(shopifyResponse => { 
     return updateCollection(mongo, 'shopify_customers', {email: customer.email}, {shopifyResponse}) 
    }).catch(err => { 
     if (!_.get(err, 'response.body.errors')) throw err 
     let shopifyResponseError = JSON.stringify(err.response.body.errors) 
     return updateCollection(mongo, 'shopify_customers', {email: customer.email}, {shopifyResponseError}) 
    }) 
    }) 
} 
+0

Вам не нужно преобразовать обещания код Rx ради преобразования, поскольку Rx отлично работает с обещаниями и потребляет их. –

+0

Эй, Бен! У меня возникают проблемы с большой цепочкой обещаний, которая перемещает много данных/дросселей api. Я хотел бы получить немного больше детализации и изучить Rx в процессе. Я ищу учебники по Bluebird для Rx, но я не могу найти ничего, что помогло бы мне понять концепции 1: 1. – ThomasReggi

ответ

0

Как Бен упомянул в своем комментарии, несколько операторов в RxJs принимают обещания и неявно преобразуют их в наблюдаемые. О цепочке обещаний следуйте за двумя ресурсами, которые помогут вам лучше понять ваше понимание. Первый из них имеет дело с цепочкой, второй также с цепочки, но фокусируется на управлении ошибок:

Смежные вопросы