Из цепочки обещаний в Rx.js

Question

У меня есть цепочка обещаний, подобная приведенной ниже, в которой есть три обещания. Сейчас я немного изучаю 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})
    })
  })
}

Answer 1

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

• RxJS Promise Composition (передача данных)
• Наблюдаемый - преобразование 2 обещаний в наблюдаемое