链接 RXJ 承诺 Observable.from

Question

在 RxJS 6 中，如何使用 Promise 链接和传递数据？我必须使用 jira-connector npm 库连续执行一堆 JIRA api 调用。但我不确定如何执行并将数据传递给函数。

谢谢！

例如：

    const pipeData = Observable.from(jira.search.search({
        jql: 'team = 41 and type = "Initiative"'
    }))

    pipeData.pipe(
        data => operators.flatMap(data.issues),
        issue => Observable.from(jira.search.search({
        jql: `team = 41 and "Parent Link" = ${issue.key}`
    }))).subscribe(results => {
        console.log(results)
    })

Answer 1

首先，您必须在管道函数中使用 lettable 运算符。

你似乎想要做的是：

1. 打一个电话，就能解决一系列问题；
2. 为每个问题单独调用；
3. 获取结果

比如：

pipeData.pipe(

    // when pipeData emits, subscribe to the following and cancel the previous subscription if there was one:
    switchMap(data => of(data.issues))),

    // now you get array of issues, so concatAll and get a stream of it:
    concatAll(),

    // now to call another HTTP call for every emit, use concatMap:
    concatMap(issue => jira.search.search({
    jql: `team = 41 and "Parent Link" = ${issue.key}`
})).subscribe(results => {
    console.log(results)
})

请注意，我没有将 jira.search.search 与 from 包装在一起，因为您也可以将承诺传递给 concatMap，您还可以传递第二个参数 - resultSelector 函数来选择其中的一些属性（如果需要）：

concatMap(issue => jira.search.search({
        jql: `team = 41 and "Parent Link" = ${issue.key}`),
        result => result.prop1
)