javascript 传感器ForkJoin组合

Posted 2021-05-03

createExecutableObservable(
  of(
    itemsByLine
    .split('\n')
  )
  .pipe(
    switchMap(itemList => (
      forkJoin(
        (
          from(itemList)
          .pipe(
            filter(Boolean),
            filter(item => (
              !(
                whitelist
                .includes(item)
              )
            )),
            map(item => (
              `*${item}*`
            )),
            toArray(),
          )
        ),
        (
          from(itemList)
          .pipe(
            filter(Boolean),
            filter(item => (
              !(
                whitelist
                .includes(item)
              )
            )),
            map(item => (
              `*.${item}.*`
            )),
            toArray(),
          )
        ),
      )
    )),
    map(([
      itemListAsterisk,
      itemListAsteriskWithDot,
    ]) => (
      itemListAsterisk
      .concat(itemListAsteriskWithDot)
    )),
  )
)
.execute()