Run results for: Rxjs several pipes vs one 100k without functional array functions at all 1253tzsd

Test name	Executions per second
✓ RxJS one pipe	317 Ops/sec
Several pipes	191 Ops/sec
Top operator	186 Ops/sec
Many pipes same function	186 Ops/sec

RxJS one pipe

let { from, Observable } = rxjs;
let { flatMap, map, tap, toArray } = rxjs.operators;

const data$ = from(rawdata)
	.pipe(
		map(values => {
            let count = 0;
			for (let i = 0; i < 50; i++) {
              count = count + 1;
            }
            return count;
        })
    )

let data;
data$.subscribe(d => data = d);

Several pipes

let { from, Observable } = rxjs;
let { flatMap, map, tap, toArray } = rxjs.operators;

const data$ = from(rawdata)
	.pipe(
		map(values => {
            let count = 0;
			for (let i = 0; i < 10; i++) {
              count = count + 1;
            }
            return count;
        }),
      		map(values => {
            let count = 0;
			for (let i = 0; i < 10; i++) {
              count = count + 1;
            }
            return count;
        }),
      		map(values => {
            let count = 0;
			for (let i = 0; i < 10; i++) {
              count = count + 1;
            }
            return count;
        }),
      map(values => {
            let count = 0;
			for (let i = 0; i < 10; i++) {
              count = count + 1;
            }
            return count;
        }),

      map(values => {
            let count = 0;
			for (let i = 0; i < 10; i++) {
              count = count + 1;
            }
            return count;
        })
    )

let data;
data$.subscribe(d => data = d);

Many pipes same function

let { from, Observable } = rxjs;
let { flatMap, map, tap, toArray } = rxjs.operators;

function myOperator(values) {
  let count = 0;
  for (let i = 0; i < 10; i++) {
    count = count + 1;
  }
  return count;
}

const data$ = from(rawdata)
	.pipe(
      map(myOperator),
      map(myOperator),
      map(myOperator),
      map(myOperator),
      map(myOperator)
    )

let data;
data$.subscribe(d => data = d);

Top operator

let { from, Observable } = rxjs;
let { flatMap, map, tap, toArray } = rxjs.operators;


const data$ = from(rawdata)
	.pipe(
      map(topOperator),
      map(topOperator),
      map(topOperator),
      map(topOperator),
      map(topOperator)
    )

let data;
data$.subscribe(d => data = d);