Как создать собственный оператор из трубы операторов в IxJS?

Question

В rxjs6 мы можем создать оператор из набора операторов.

import { pipe } from 'rxjs';

function doSomething() {
   return pipe(
       map(...),
       flatMap(...),
   );
}

$.pipe(
   map(...),
   doSomething(),
   flatMap(...),
)

Есть ли способ создать такой оператор в IxJS?

Answer 1

Вы можете комбинировать операторы вручную:

import { IterableX as Iterable } from 'ix/iterable';
import { map, filter } from 'ix/iterable/pipe/index';

function customOperator() {
  return source$ => map(x => x * x)(
    filter(x => x % 2 === 0)
    (source$)
  );
}

const results = Iterable.of(1, 2, 3, 4).pipe(
  customOperator()
).forEach(x => console.log(`Next ${x}`));

Или написать свою собственную pipe реализацию:

const pipe = (...fns) =>
  source$ => fns.reduce(
    (acc, fn) => fn(acc),
    source$
  );

function customOperator() {
  return pipe(
    filter(x => x % 2 === 0),
    map(x => x * x)
  )
}